public void start() {
        if (!queue.isPresent()) {
            initQueue();
        }
        queue.ifPresent(actualQueue -> actualQueue.startListener(EventBusQueueAdapter.this::sendToEventManager));
    }
public void start() {
        if (!queue.isPresent()) {
            initQueue();
        }
        queue.ifPresent(actualQueue -> actualQueue.startListener(EventBusQueueAdapter.this::sendToEventManager));
    }
public void start ( ) { if ( ! queue . isPresent ( ) ) { initQueue ( ) ; } queue . ifPresent ( actualQueue -> actualQueue . startListener ( EventBusQueueAdapter . this :: sendToEventManager ) ) ; }
Start listener. Once this is called messages can come in on a foreign thread.
Start listener . Once this is called messages can come in on a foreign thread .