run

open override fun run()

Starts the event dispatcher by subscribing to event streams.

This method initializes subscriptions to both domain event streams and state event streams. Events are grouped by aggregate and distributed to appropriate aggregate dispatchers. If no topics are available for subscription, appropriate warnings are logged.

See also