curator-recipes/src/main/java/org/apache/curator/framework/recipes/queue/DistributedIdQueue.java [57:68]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            CuratorFramework client,
            QueueConsumer<T> consumer,
            QueueSerializer<T> serializer,
            String queuePath,
            ThreadFactory threadFactory,
            Executor executor,
            int minItemsBeforeRefresh,
            boolean refreshOnWatch,
            String lockPath,
            int maxItems,
            boolean putInBackground,
            int finalFlushMs) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



curator-recipes/src/main/java/org/apache/curator/framework/recipes/queue/DistributedQueue.java [108:119]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            CuratorFramework client,
            QueueConsumer<T> consumer,
            QueueSerializer<T> serializer,
            String queuePath,
            ThreadFactory threadFactory,
            Executor executor,
            int minItemsBeforeRefresh,
            boolean refreshOnWatch,
            String lockPath,
            int maxItems,
            boolean putInBackground,
            int finalFlushMs) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -