org.nuxeo.ecm.platform.importer.queue.manager

Class CQManager

java.lang.Object

org.nuxeo.ecm.platform.importer.queue.manager.AbstractQueuesManager

org.nuxeo.ecm.platform.importer.queue.manager.CQManager

All Implemented Interfaces:

AutoCloseable, QueuesManager

public class CQManager
extends AbstractQueuesManager

Since:

8.10

Field Summary

Fields inherited from class org.nuxeo.ecm.platform.importer.queue.manager.AbstractQueuesManager

log, queuesNb

Constructor Summary

Constructors

Constructor and Description
CQManager(File basePath, ImporterLogger logger, int queuesNb, boolean append)
CQManager(ImporterLogger logger, int queuesNb)
CQManager(ImporterLogger logger, int queuesNb, boolean append)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	isEmpty(int queue) Returns true if there is no element in the queue.
SourceNode	poll(int queue) Get a node from a queue.
SourceNode	poll(int queue, long timeout, TimeUnit unit) Get a node from a queue, with a timeout.
void	put(int queue, SourceNode node) Put a node into a queue.
int	size(int queue) Returns the number of elements in the queue.

Methods inherited from class org.nuxeo.ecm.platform.importer.queue.manager.AbstractQueuesManager

count

Methods inherited from class java.lang.Object

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

Constructor Detail

CQManager

public CQManager(ImporterLogger logger,
                 int queuesNb)

CQManager

public CQManager(ImporterLogger logger,
                 int queuesNb,
                 boolean append)

CQManager

public CQManager(File basePath,
                 ImporterLogger logger,
                 int queuesNb,
                 boolean append)

Method Detail

put

public void put(int queue,
                SourceNode node)
         throws InterruptedException

Description copied from interface: QueuesManager

Put a node into a queue.

Throws:

InterruptedException

poll

public SourceNode poll(int queue)

Description copied from interface: QueuesManager

Get a node from a queue.

poll

public SourceNode poll(int queue,
                       long timeout,
                       TimeUnit unit)
                throws InterruptedException

Description copied from interface: QueuesManager

Get a node from a queue, with a timeout.

Throws:

InterruptedException

isEmpty

public boolean isEmpty(int queue)

Description copied from interface: QueuesManager

Returns true if there is no element in the queue.

size

public int size(int queue)

Description copied from interface: QueuesManager

Returns the number of elements in the queue.

close

public void close()