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

Interface MQueues.Tailer<M>

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

CQTailer

Enclosing interface:

MQueues<M extends Message>

public static interface MQueues.Tailer<M>
extends AutoCloseable

Sequential reader for a queue. A tailer is not thread safe and should not be shared by multiple threads.

Method Summary

Modifier and Type	Method and Description
Offset	commit() Commit the offset of the last message returned by read.
int	getQueue() Returns the associated queue index.
M	read(Duration timeout) Read a message from the queue within the timeout.
void	toEnd() Go to the end of the queue.
void	toLastCommitted() Go just after the last committed message.
void	toStart() Go to the beginning of the queue.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

read

M read(Duration timeout)
throws InterruptedException

Read a message from the queue within the timeout.

Returns:

null if there is no message in the queue after the timeout.

Throws:

InterruptedException

toEnd

void toEnd()

Go to the end of the queue.

toStart

void toStart()

Go to the beginning of the queue.

toLastCommitted

void toLastCommitted()

Go just after the last committed message.

commit

Offset commit()

Commit the offset of the last message returned by read.

getQueue

int getQueue()

Returns the associated queue index.