Package | Description |
---|---|
org.apache.curator.framework.recipes.queue |
Class and Description |
---|
DistributedDelayQueue
A variation of the DistributedPriorityQueue that uses time as the priority.
|
DistributedIdQueue
A version of
DistributedQueue that allows IDs to be associated with queue items. |
DistributedPriorityQueue
An implementation of the Distributed Priority Queue ZK recipe.
|
DistributedQueue
An implementation of the Distributed Queue ZK recipe.
|
DistributedQueue.ProcessType |
ErrorMode
Used when the queue is created with a
QueueBuilder.lockPath(String) . |
MultiItem
Abstraction for multiple items.
|
QueueAllocator |
QueueBase |
QueueBuilder
The builder for both
DistributedQueue and DistributedPriorityQueue |
QueueConsumer
Message Consumer
|
QueuePutListener
Queue puts are done in the background.
|
QueueSerializer
Helper to serialize/deserialize queue items
|
QueueSharderPolicies
Various policies/options for sharding.
|
QueueSharderPolicies.Builder |
Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.