private void listen(ObservableQueue queue) {
        queue.observe().subscribe((Message msg) -> defaultEventProcessor.handle(queue, msg));
    }
@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