Interface | Description |
---|---|
MultiItem<T> |
Abstraction for multiple items.
|
QueueAllocator<U,T extends QueueBase<U>> | |
QueueBase<T> | |
QueueConsumer<T> |
Message Consumer
|
QueuePutListener<T> |
Queue puts are done in the background.
|
QueueSerializer<T> |
Helper to serialize/deserialize queue items
|
Class | Description |
---|---|
BlockingQueueConsumer<T> |
Utility - a queue consumer that provides behavior similar to a
BlockingQueue |
DistributedDelayQueue<T> |
A variation of the DistributedPriorityQueue that uses time as the priority.
|
DistributedIdQueue<T> |
A version of
DistributedQueue that allows IDs to be associated with queue items. |
DistributedPriorityQueue<T> |
An implementation of the Distributed Priority Queue ZK recipe.
|
DistributedQueue<T> |
An implementation of the Distributed Queue ZK recipe.
|
QueueBuilder<T> |
The builder for both
DistributedQueue and DistributedPriorityQueue |
QueueSafety<T> |
Parameter block for specifying queue safety with either
DistributedQueue or
DistributedPriorityQueue |
QueueSharder<U,T extends QueueBase<U>> |
A utility for shard a distributed queue.
|
QueueSharderPolicies |
Various policies/options for sharding.
|
QueueSharderPolicies.Builder | |
SimpleDistributedQueue |
Drop in replacement for: org.apache.zookeeper.recipes.queue.DistributedQueue that is part of
the ZooKeeper distribution
|
Enum | Description |
---|---|
DistributedQueue.ProcessType | |
ErrorMode |
Used when the queue is created with a
QueueBuilder.lockPath(String) . |