Create a Dispatcher, .notify() it about new messages, and use the returned Consumer in message handlers.
Dispatcher
.notify()
Consumer