public class DistributedQueue<T extends Serializable> extends Object
DistributedQueue(ZkClient zkClient, String root)
boolean
isEmpty()
offer(T element)
T
peek()
poll()
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public DistributedQueue(ZkClient zkClient, String root)
public boolean offer(T element)
public T poll()
public boolean isEmpty()
public T peek()
Copyright © 2019. All rights reserved.