AggregateEventDispatcher

constructor(name: String = "-", namedAggregate: NamedAggregate, messageFlux: Flux<EventStreamExchange>, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, eventHandler: EventHandler, scheduler: Scheduler, messageReadiness: Mono<Void> = Mono.empty(), processingAdmission: () -> Unit = {}, processingQuiescence: () -> Unit = {})

Creates a new AggregateEventDispatcher with the specified parameters

messageReadiness

Completion of asynchronous message-source setup when this dispatcher is registered directly with a runtime

processingAdmission

Explicit transport-processing gate opened by start

processingQuiescence

Logical transport gate closed by quiesce