AggregateCommandDispatcher
constructor(name: String = "-", aggregateMetadata: AggregateMetadata<C, S>, messageFlux: Flux<ServerCommandExchange<*>>, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, commandHandler: CommandHandler, scheduler: Scheduler)
Parameters
parallelism
The level of parallelism for message processing.
scheduler
The scheduler for handling messages.
messageFlux
The flux of command exchanges to process.
name
The name of this dispatcher.
commandHandler
The command handler for processing commands.
Type Parameters
C
The type of the command aggregate root.
S
The type of the state aggregate.