<dependencies> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>5.2.0</version> </dependency> </dependencies> import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.recipes.queue.DistributedQueue; import org.apache.curator.framework.recipes.queue.QueueBuilder; public class DistributedQueueExample { public static void main(String[] args) throws Exception { DistributedQueue<String> queue = QueueBuilder.builder(client, null, null, null) .buildQueue(); } } QueueBuilder.builder(client, null, null, null) .buildQueue() .add("task1"); String task = QueueBuilder.builder(client, null, null, null) .buildQueue() .take(); QueueBuilder.builder(client, null, null, null) .buildQueue() .addListener(new DistributedQueueListener<String>() { public void itemAdded(String item) { } public void itemRemoved(String item) { } });