org.I0Itec.zkclient
Class DistributedQueue<T extends java.io.Serializable>

java.lang.Object
  extended by org.I0Itec.zkclient.DistributedQueue<T>

public class DistributedQueue<T extends java.io.Serializable>
extends java.lang.Object


Constructor Summary
DistributedQueue(ZkClient zkClient, java.lang.String root)
           
 
Method Summary
 boolean isEmpty()
           
 boolean offer(T element)
           
 T peek()
           
 T poll()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DistributedQueue

public DistributedQueue(ZkClient zkClient,
                        java.lang.String root)
Method Detail

offer

public boolean offer(T element)

poll

public T poll()

isEmpty

public boolean isEmpty()

peek

public T peek()