newAggregateDispatcher
open override fun newAggregateDispatcher(namedAggregate: NamedAggregate, messageFlux: Flux<StateEventExchange<*>>): MessageDispatcher
Creates a new message dispatcher for a specific named aggregate.
This method is responsible for instantiating a dispatcher that will handle messages for a single aggregate. The dispatcher should process messages from the provided flux and manage the aggregate's state or behavior accordingly.
Return
A new MessageDispatcher instance configured for the specified aggregate.
Parameters
namedAggregate
The named aggregate for which the dispatcher is created. Must not be null.
messageFlux
The flux of messages for the aggregate. May be empty.
Throws
if the namedAggregate is invalid or if messageFlux is null.
if dispatcher creation fails due to configuration issues.