Class OverseerTaskQueue

  • All Implemented Interfaces:
    DistributedQueue

    public class OverseerTaskQueue
    extends ZkDistributedQueue
    A ZkDistributedQueue augmented with helper methods specific to the overseer task queues. Methods specific to this subclass ignore superclass internal state and hit ZK directly. This is inefficient! But the API on this class is kind of muddy..