public class ChronicleMQOffsetTracker extends Object implements AutoCloseable
Constructor and Description |
---|
ChronicleMQOffsetTracker(String basePath,
int queue,
String group) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
commit(long offset) |
long |
getLastCommittedOffset()
Use a cache to return the last committed offset, concurrent consumer is not taken in account
use
readLastCommittedOffset() in concurrency. |
long |
readLastCommittedOffset()
Read the last committed offset from the file.
|
public ChronicleMQOffsetTracker(String basePath, int queue, String group)
public long getLastCommittedOffset()
readLastCommittedOffset()
in concurrency.public long readLastCommittedOffset()
public void commit(long offset)
public void close()
close
in interface AutoCloseable
Copyright © 2017 Nuxeo. All rights reserved.