wow-core/me.ahoo.wow.saga.stateless/StatelessSagaDispatcher

StatelessSagaDispatcher

class StatelessSagaDispatcher(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: StatelessSagaFunctionRegistrar, eventHandler: StatelessSagaHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("SagaDispatcher")) : CompositeEventDispatcher

Dispatcher for stateless sagas that handles domain events and coordinates command execution. This dispatcher extends CompositeEventDispatcher to provide event-driven processing for sagas that don't maintain state between events.

Constructors

constructor(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: StatelessSagaFunctionRegistrar, eventHandler: StatelessSagaHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("SagaDispatcher"))

Properties

name

open override val name: String

The name of this dispatcher, typically formatted as applicationName.DomainEventDispatcher.

Functions

open override fun close()

Closes this resource by performing a graceful shutdown.

start

open override fun start()

Starts the composite event dispatcher by initializing and starting both the event stream dispatcher and state event dispatcher.

stop

open fun stop()

Synchronously closes this resource with graceful shutdown.

open fun stop(timeout: Duration)

Synchronously closes this resource with graceful shutdown within a specified timeout.

stopGracefully

open override fun stopGracefully(): Mono<Void>

Stops the composite event dispatcher gracefully by stopping both the event stream dispatcher and state event dispatcher.