EventStreamDispatcher

Constructors

constructor(name: String, parallelism: Int, messageBus: DomainEventBus, 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.

override fun forceStop()

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

Creates a new message dispatcher for a specific named aggregate.

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

Starts the dispatcher by running all aggregate dispatchers.

override fun quiesce()

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

Creates a flux of messages for the specified subscription.

override fun start()

override fun stopGracefully(): Mono<Void>

Stops the dispatcher gracefully by shutting down all aggregate dispatchers.