Package org.apache.curator.framework.recipes.queue
package org.apache.curator.framework.recipes.queue
-
ClassDescriptionUtility - a queue consumer that provides behavior similar to a
BlockingQueueA variation of the DistributedPriorityQueue that uses time as the priority.A version ofDistributedQueuethat 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 bothDistributedQueueandDistributedPriorityQueueMessage ConsumerQueue puts are done in the background.QueueSafety<T>Parameter block for specifying queue safety with eitherDistributedQueueorDistributedPriorityQueueHelper 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