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

StatelessSagaDispatcher

class StatelessSagaDispatcher(val name: String, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val domainEventBus: DomainEventBus, val stateEventBus: StateEventBus, val functionRegistrar: StatelessSagaFunctionRegistrar, val eventHandler: StatelessSagaHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("SagaDispatcher")) : AbstractEventDispatcher<Mono<*>>

Constructors

StatelessSagaDispatcher

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

Properties

open override val domainEventBus: DomainEventBus

open override val eventHandler: StatelessSagaHandler

functionRegistrar

open override val functionRegistrar: StatelessSagaFunctionRegistrar

open override val name: String

named like applicationName.StatelessSagaDispatcher

open override val parallelism: Int

open override val stateEventBus: StateEventBus

Functions

open override fun close()

open override fun run()