AggregateEventDispatcher
constructor(name: String = "-", namedAggregate: NamedAggregate, messageFlux: Flux<EventStreamExchange>, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, eventHandler: EventHandler, scheduler: Scheduler)
Creates a new AggregateEventDispatcher with the specified parameters