Uses of Class
org.apache.curator.framework.recipes.queue.QueueBuilder
-
Uses of QueueBuilder in org.apache.curator.framework.recipes.queue
Modifier and TypeMethodDescriptionstatic <T> QueueBuilder
<T> QueueBuilder.builder
(CuratorFramework client, QueueConsumer<T> consumer, QueueSerializer<T> serializer, String queuePath) Allocate a new builderChange the executor used.QueueBuilder.finalFlushTime
(int time, TimeUnit unit) Sets an amount of time to callDistributedQueue.flushPuts(long, TimeUnit)
when the queue is closed.Without a lock set, queue items are removed before being sent to the queue consumer.QueueBuilder.maxItems
(int maxItems) By default, the various queues are unbounded.QueueBuilder.putInBackground
(boolean putInBackground) By default, messages are added in the background.QueueBuilder.threadFactory
(ThreadFactory factory) Change the thread factory used.