Use a MessageProducer<T> for sending or publishing to the event bus instead of WriteStream<T>
Overload EventBus consumer and localConsumer to accept the consumer handler for immediate registration