A drop-in replacement for the DistributedQueue that comes with the ZK distribution.
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
It is strongly recommended that you add a ConnectionStateListener and watch for SUSPENDED and LOST state changes.