StatelessSagaDispatcher
constructor(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: StatelessSagaFunctionRegistrar, eventHandler: StatelessSagaHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("SagaDispatcher"))
Parameters
name
The name of the dispatcher, typically formatted as applicationName.StatelessSagaDispatcher.
parallelism
The number of parallel threads for processing messages (default: MessageParallelism.DEFAULT_PARALLELISM).
domainEventBus
The bus for publishing domain events.
stateEventBus
The bus for publishing state events.
functionRegistrar
The registrar for stateless saga functions.
eventHandler
The handler for processing domain events.
schedulerSupplier
The supplier for aggregate schedulers (default: DefaultAggregateSchedulerSupplier with "SagaDispatcher" prefix).