org.nuxeo.ecm.core.work.redis

Class RedisBlockingQueue

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<Runnable>

org.nuxeo.ecm.core.work.NuxeoBlockingQueue

org.nuxeo.ecm.core.work.redis.RedisBlockingQueue

All Implemented Interfaces:

Iterable<Runnable>, Collection<Runnable>, BlockingQueue<Runnable>, Queue<Runnable>

public class RedisBlockingQueue
extends NuxeoBlockingQueue

Redis-based BlockingQueue.

It has unlimited capacity, so never blocks on NuxeoBlockingQueue.put(java.lang.Runnable) and NuxeoBlockingQueue.offer(java.lang.Runnable) always returns true.

Since:

5.8

Constructor Summary

Constructors

Constructor and Description
RedisBlockingQueue(String queueId, RedisWorkQueuing queuing)

Method Summary

Methods

Modifier and Type	Method and Description
int	getQueueSize() Gets the size of the queue.
Runnable	pollElement() Retrieves and removes an element from the queue, or returns null if the queue is empty.
void	putElement(Runnable r) Adds an element into this queue, waiting if necessary for space to become available.

Methods inherited from class org.nuxeo.ecm.core.work.NuxeoBlockingQueue

contains, drainTo, drainTo, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, setActive, size, take

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.BlockingQueue

add, remove

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, isEmpty, removeAll, retainAll, toArray, toArray

Constructor Detail

RedisBlockingQueue

public RedisBlockingQueue(String queueId,
                  RedisWorkQueuing queuing)

Method Detail

getQueueSize

public int getQueueSize()

Description copied from class: NuxeoBlockingQueue

Gets the size of the queue.

Specified by:

getQueueSize in class NuxeoBlockingQueue

putElement

public void putElement(Runnable r)

Description copied from class: NuxeoBlockingQueue

Adds an element into this queue, waiting if necessary for space to become available.

Specified by:

putElement in class NuxeoBlockingQueue

pollElement

public Runnable pollElement()

Description copied from class: NuxeoBlockingQueue

Retrieves and removes an element from the queue, or returns null if the queue is empty.

Specified by:

pollElement in class NuxeoBlockingQueue