public class QueueSafety<T> extends Object
DistributedQueue
or
DistributedPriorityQueue
public QueueSafety(String lockPath, QueueConsumer<T> consumer)
lockPath
- ZKPath to use for locking purposesconsumer
- the message consumerCopyright © 2011–2023 The Apache Software Foundation. All rights reserved.