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

Class BQManager

java.lang.Object

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

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

All Implemented Interfaces:

AutoCloseable, QueuesManager

public class BQManager
extends AbstractQueuesManager

Blocking Queues Manager, in memory queues

Since:

8.10

Field Summary

Fields

Modifier and Type	Field and Description
protected int	maxQueueSize

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

log, queuesNb

Constructor Summary

Constructors

Constructor and Description
BQManager(ImporterLogger logger, int queuesNb, int maxQueueSize)

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

Field Detail

maxQueueSize

protected final int maxQueueSize

Constructor Detail

BQManager

public BQManager(ImporterLogger logger,
                 int queuesNb,
                 int maxQueueSize)

Method Detail

isEmpty

public boolean isEmpty(int queue)

Description copied from interface: QueuesManager

Returns true if there is no element in the 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

size

public int size(int queue)

Description copied from interface: QueuesManager

Returns the number of elements in the queue.

poll

public SourceNode poll(int queue)

Description copied from interface: QueuesManager

Get a node from a queue.

put

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

Description copied from interface: QueuesManager

Put a node into a queue.

Throws:

InterruptedException

close

public void close()