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