Class ZkDistributedQueue

  • All Implemented Interfaces:
    DistributedQueue
    Direct Known Subclasses:
    OverseerTaskQueue

    public class ZkDistributedQueue
    extends Object
    implements DistributedQueue
    A ZK-based distributed queue. Optimized for single-consumer, multiple-producer: if there are multiple consumers on the same ZK queue, the results should be correct but inefficient