qbit/core/src/main/java/io/advantageous/qbit/events/EventBusQueueAdapter.java
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.