Simple Distributed Queue

1. IMPORTANT – We recommend that you do NOT use ZooKeeper for Queues. Please see Tech Note 4 for details.

Description

A drop-in replacement for the DistributedQueue that comes with the ZK distribution.

Participating Classes

• SimpleDistributedQueue

Usage

Creating a SimpleDistributedQueue

public SimpleDistributedQueue(CuratorFramework client,
                              String path)
Parameters:
client - the client
path - path to store queue nodes

Add to the queue

public boolean offer(byte[] data)
             throws Exception
Inserts data into queue.
Parameters:
data - the data
Returns:
true if data was successfully added

Take from the queue

public byte[] take()
           throws Exception
Removes the head of the queue and returns it, blocks until it succeeds.
Returns:
The former head of the queue

NOTE: see the Javadoc for additional methods