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

StateEventDispatcher

class StateEventDispatcher(val name: String, val parallelism: Int, val messageBus: StateEventBus, val functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, val eventHandler: EventHandler, val schedulerSupplier: AggregateSchedulerSupplier, metrics: WowMetrics = WowMetrics.NONE) : AbstractEventDispatcher<StateEventExchange<*>, StateEventBus>

Constructors

StateEventDispatcher

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

Properties

open override val eventHandler: EventHandler

The event handler for processing events.

functionRegistrar

open override val functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

The registrar containing event processing functions.

open override val messageBus: StateEventBus

The message bus for sending and receiving events.

open override val name: String

open override val parallelism: Int

The level of parallelism for processing events.

schedulerSupplier

open override val schedulerSupplier: AggregateSchedulerSupplier

Functions

newAggregateDispatcher

open override fun newAggregateDispatcher(namedAggregate: NamedAggregate, messageFlux: Flux<StateEventExchange<*>>): MessageDispatcher

Creates a new message dispatcher for a specific named aggregate.