In-process MessageBus implementation using Phoenix.PubSub.

Commands are dispatched to a single registered handler (point-to-point). Events are broadcast to all subscribers.

Ack/nack is synchronous: the handler return value determines the outcome.

Setup

Add the registry to your supervision tree (done automatically if using Orkestra):

Orkestra.MessageBus.PubSub