wow-core/me.ahoo.wow.event.dispatcher/DomainEventDispatcher

DomainEventDispatcher

class DomainEventDispatcher(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: DomainEventFunctionRegistrar, eventHandler: DomainEventHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("EventDispatcher")) : CompositeEventDispatcher

Domain Event Dispatcher responsible for coordinating the processing of domain events.

This class extends AbstractEventDispatcher to provide concrete implementation for handling domain events through the event bus system. It manages the lifecycle of event processing, including subscription to event streams and distribution of events to appropriate handlers.

Constructors

constructor(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: DomainEventFunctionRegistrar, eventHandler: DomainEventHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("EventDispatcher"))

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.

DomainEventDispatcher

See also

Constructors

Properties

Functions