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 = {}, metrics: WowMetrics = WowMetrics.NONE)
Creates a new AggregateEventDispatcher with the specified parameters
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
metrics
Instance-scoped metrics recorder for dispatcher operations