public class QueueSafety<T>
extends java.lang.Object
DistributedQueue
or
DistributedPriorityQueue
Constructor and Description |
---|
QueueSafety(java.lang.String lockPath,
QueueConsumer<T> consumer) |
public QueueSafety(java.lang.String lockPath, QueueConsumer<T> consumer)
lockPath
- ZKPath to use for locking purposesconsumer
- the message consumer