org.nuxeo.ecm.platform.importer.mqueues.mqueues.chronicle

Class ChronicleMQOffsetTracker

java.lang.Object

org.nuxeo.ecm.platform.importer.mqueues.mqueues.chronicle.ChronicleMQOffsetTracker

All Implemented Interfaces:

AutoCloseable

public class ChronicleMQOffsetTracker
extends Object
implements AutoCloseable

Track committed offset for a queue.

Since:

9.1

Constructor Summary

Constructors

Constructor and Description
ChronicleMQOffsetTracker(String basePath, int queue, String group)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ChronicleMQOffsetTracker

public ChronicleMQOffsetTracker(String basePath,
                                int queue,
                                String group)

Method Detail

getLastCommittedOffset

public long getLastCommittedOffset()

Use a cache to return the last committed offset, concurrent consumer is not taken in account use readLastCommittedOffset() in concurrency.

readLastCommittedOffset

public long readLastCommittedOffset()

Read the last committed offset from the file.

commit

public void commit(long offset)

close

public void close()

Specified by:

close in interface AutoCloseable