DomainEventDispatcher
constructor(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: DomainEventFunctionRegistrar, eventHandler: DomainEventHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("EventDispatcher"))
Parameters
name
The name of this dispatcher, typically formatted as applicationName.DomainEventDispatcher
parallelism
The level of parallelism for processing events (default: 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