Uses of Class
org.apache.curator.framework.recipes.queue.QueueBuilder
Packages that use QueueBuilder
-
Uses of QueueBuilder in org.apache.curator.framework.recipes.queue
Methods in org.apache.curator.framework.recipes.queue that return QueueBuilderModifier 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.