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 .