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.

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).

Constructors

StatelessSagaDispatcher

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

forceStop

override fun forceStop()

Releases resources promptly without blocking, and remains safe before prepare and across repeated or overlapping calls.

prepare

override fun prepare(runtimeContext: RuntimeContext): Mono<Void>

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

quiesce

override fun quiesce()

Stops admitting new work after the runtime has atomically closed global admission.

start

override fun start()

stopGracefully

override fun stopGracefully(): Mono<Void>

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