newAggregateDispatcher

abstract fun newAggregateDispatcher(namedAggregate: NamedAggregate, messageFlux: Flux<T>): MessageDispatcher

Creates a new message dispatcher for a specific named aggregate.

Return

A new message dispatcher instance

Parameters

namedAggregate

The named aggregate for the dispatcher

messageFlux

The flux of messages for the aggregate