@Override
    public void doStop() {
        eventToQueueMap.forEach(
                (event, queue) -> {
                    LOGGER.info("Stop listening for events: {}", event);
                    queue.stop();
                });
        defaultQueues.forEach(
                (status, queue) -> {
                    LOGGER.info(
                            "Stop listening on default queue {} for status {}",
                            status,
                            queue.getName());
                    queue.stop();
                });
    }
@return Returns a map of queues which are active. Key is event name and value is queue URI
core/src/main/java/com/netflix/conductor/core/events/DefaultEventQueueManager.java