StateEventDispatcher

Constructors

constructor(name: String, parallelism: Int, messageBus: StateEventBus, functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, eventHandler: EventHandler, schedulerSupplier: AggregateSchedulerSupplier)

The event handler for processing events.

The registrar containing event processing functions.

The message bus for sending and receiving events.

open override val name: String

The set of named aggregates that this dispatcher will manage.

open override val parallelism: Int

The level of parallelism for processing events.

open override fun close()

Closes this resource by performing a graceful shutdown.

Creates a new message dispatcher for a specific named aggregate.

open override fun receiveMessage(namedAggregate: NamedAggregate): Flux<StateEventExchange<*>>

Creates a flux of messages for the specified named aggregate.

open override fun start()

Starts the dispatcher by running all aggregate dispatchers.

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.

open override fun stopGracefully(): Mono<Void>

Stops the dispatcher gracefully by shutting down all aggregate dispatchers.