Package org.apache.curator.framework.recipes.queue
package org.apache.curator.framework.recipes.queue
-
ClassDescriptionUtility - a queue consumer that provides behavior similar to a
BlockingQueue
A variation of the DistributedPriorityQueue that uses time as the priority.A version ofDistributedQueue
that allows IDs to be associated with queue items.An implementation of the Distributed Priority Queue ZK recipe.An implementation of the Distributed Queue ZK recipe.Used when the queue is created with aQueueBuilder.lockPath(String)
.MultiItem<T>Abstraction for multiple items.QueueAllocator<U,T extends QueueBase<U>> QueueBase<T>QueueBuilder<T>The builder for bothDistributedQueue
andDistributedPriorityQueue
Message ConsumerQueue puts are done in the background.QueueSafety<T>Parameter block for specifying queue safety with eitherDistributedQueue
orDistributedPriorityQueue
Helper to serialize/deserialize queue itemsQueueSharder<U,T extends QueueBase<U>> A utility for shard a distributed queue.Various policies/options for sharding.Drop in replacement for: org.apache.zookeeper.recipes.queue.DistributedQueue that is part of the ZooKeeper distribution