AggregateCommandDispatcher
constructor(aggregateMetadata: AggregateMetadata<C, S>, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, scheduler: Scheduler, messageFlux: Flux<ServerCommandExchange<*>>, name: String = "-", aggregateProcessorFactory: AggregateProcessorFactory, commandHandler: CommandHandler, serviceProvider: ServiceProvider)
Parameters
C
The type of the command aggregate root.
S
The type of the state aggregate.
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.
aggregateProcessorFactory
Factory for creating aggregate processors.
commandHandler
The command handler for processing commands.
serviceProvider
Provider for accessing services.