Package | Description |
---|---|
org.apache.curator.framework.recipes.queue |
Modifier and Type | Method and Description |
---|---|
void |
DistributedQueue.putMulti(MultiItem<T> items)
Add a set of items into the queue.
|
void |
DistributedPriorityQueue.putMulti(MultiItem<T> items,
int priority)
Add a set of items with the same priority into the queue.
|
boolean |
DistributedPriorityQueue.putMulti(MultiItem<T> items,
int priority,
int maxWait,
TimeUnit unit)
Same as
DistributedPriorityQueue.putMulti(MultiItem, int) but allows a maximum wait time if an upper bound was set
via QueueBuilder.maxItems . |
boolean |
DistributedQueue.putMulti(MultiItem<T> items,
int maxWait,
TimeUnit unit)
Same as
DistributedQueue.putMulti(MultiItem) but allows a maximum wait time if an upper bound was set
via QueueBuilder.maxItems . |
void |
DistributedDelayQueue.putMulti(MultiItem<T> items,
long delayUntilEpoch)
Add a set of items with the same priority into the queue.
|
boolean |
DistributedDelayQueue.putMulti(MultiItem<T> items,
long delayUntilEpoch,
int maxWait,
TimeUnit unit)
Same as
DistributedDelayQueue.putMulti(MultiItem, long) but allows a maximum wait time if an upper bound was set
via QueueBuilder.maxItems . |
void |
QueuePutListener.putMultiCompleted(MultiItem<T> items)
Notification that a multi item put has completed
|
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.