@Override
    public void stop() {
        LOGGER.info("Stopped listening to {}:{}", getClass().getSimpleName(), queueName);
        running = false;
    }
An {@link ObservableQueue} implementation using the underlying {@link QueueDAO} implementation.
core/src/main/java/com/netflix/conductor/core/events/queue/ConductorObservableQueue.java