AggregateCommandDispatcher
constructor(aggregateMetadata: AggregateMetadata<C, S>, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, scheduler: Scheduler, messageFlux: Flux<ServerCommandExchange<*>>, name: String = "-", aggregateProcessorFactory: AggregateProcessorFactory, commandHandler: CommandHandler, serviceProvider: ServiceProvider)