LeaderSelector selector = new LeaderSelector(client, "/leaderPath", new MyLeaderSelectorListener()); selector.autoRequeue(); selector.start(); InterProcessMutex lock = new InterProcessMutex(client, "/lockPath"); if (lock.acquire(10, TimeUnit.SECONDS)) { try { } finally { lock.release(); } } DistributedAtomicLong counter = new DistributedAtomicLong(client, "/counterPath", new RetryNTimes(3, 1000)); counter.increment();