CompositeEventDispatcher
constructor(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, eventHandler: EventHandler, schedulerSupplier: AggregateSchedulerSupplier)
Parameters
name
The name of this dispatcher, typically formatted as applicationName.DomainEventDispatcher.
parallelism
The level of parallelism for processing events. Defaults to MessageParallelism.DEFAULT_PARALLELISM.
domainEventBus
The domain event bus for publishing and subscribing to domain events.
stateEventBus
The state event bus for handling state-related events.
functionRegistrar
The registrar for domain event handler functions.
eventHandler
The event handler for processing domain events.
schedulerSupplier
Supplier for creating schedulers for aggregate processing. Defaults to a default implementation.