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

Class CQMQueues<M extends Message>

java.lang.Object

org.nuxeo.ecm.platform.importer.mqueues.mqueues.CQMQueues<M>

All Implemented Interfaces:

AutoCloseable, MQueues<M>

public class CQMQueues<M extends Message>
extends Object
implements MQueues<M>

Chronicle Queue implementation of MQueues. Note that for performance reason the class loader assertion are disabled.

Since:

9.1

Nested Class Summary

Nested classes/interfaces inherited from interface org.nuxeo.ecm.platform.importer.mqueues.mqueues.MQueues

MQueues.Tailer<M>

Constructor Summary

Constructors

Constructor and Description
CQMQueues(File basePath) Open an existing mqueues.
CQMQueues(File basePath, int size) Create a new mqueues.

Method Summary

Modifier and Type	Method and Description
CQOffset	append(int queue, M message) Append a message into a queue, returns an Offset.
void	close()
MQueues.Tailer<M>	createTailer(int queue) Create a new MQueues.Tailer associed with the queue index.
MQueues.Tailer<M>	createTailer(int queue, String name) Create a new MQueues.Tailer associed to a queue index, using a specified offset name space.
int	size() Returns the size of the mqueues: the number of queues.
boolean	waitFor(Offset offset, Duration timeout) Wait for consumer to process a message up to the offset.

Methods inherited from class java.lang.Object

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

Constructor Detail

CQMQueues

public CQMQueues(File basePath,
                 int size)

Create a new mqueues. Warning this will ERASE the basePath if not empty.

CQMQueues

public CQMQueues(File basePath)

Open an existing mqueues.

Method Detail

size

public int size()

Description copied from interface: MQueues

Returns the size of the mqueues: the number of queues.

Specified by:

size in interface MQueues<M extends Message>

append

public CQOffset append(int queue,
                       M message)

Description copied from interface: MQueues

Append a message into a queue, returns an Offset. This method is thread safe, a queue can be shared by multiple producers.

Specified by:

append in interface MQueues<M extends Message>

Parameters:

queue - index lower than MQueues.size()

createTailer

public MQueues.Tailer<M> createTailer(int queue)

Description copied from interface: MQueues

Create a new MQueues.Tailer associed with the queue index. The committed offset is presisted in the default namespace. There can be one and only one consumer for queue in a namespace. A tailer is not thread safe.

Specified by:

createTailer in interface MQueues<M extends Message>

createTailer

public MQueues.Tailer<M> createTailer(int queue,
                                      String name)

Description copied from interface: MQueues

Create a new MQueues.Tailer associed to a queue index, using a specified offset name space. The committed offset position is shared by all tailers of the same queue with the same name. There can be one and only one consumer for queue in a namespace A tailer is not thread safe.

Specified by:

createTailer in interface MQueues<M extends Message>

waitFor

public boolean waitFor(Offset offset,
                       Duration timeout)
                throws InterruptedException

Description copied from interface: MQueues

Wait for consumer to process a message up to the offset. The message is processed if a consumer commit its offset (or a bigger one) in the default name space. Return true if the message has been consumed, false in case of timeout.

Specified by:

waitFor in interface MQueues<M extends Message>

Throws:

InterruptedException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception