wow-core/me.ahoo.wow.projection/ProjectionDispatcher

ProjectionDispatcher

class ProjectionDispatcher(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: ProjectionFunctionRegistrar, eventHandler: ProjectionHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("ProjectionDispatcher")) : CompositeEventDispatcher

Dispatcher for projections that handles domain events and coordinates projection processing. This dispatcher extends CompositeEventDispatcher to provide event-driven processing for projections that transform domain events into read models or perform side effects.

Constructors

constructor(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: ProjectionFunctionRegistrar, eventHandler: ProjectionHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("ProjectionDispatcher"))

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.