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

AggregateStateEventDispatcher

class AggregateStateEventDispatcher(val name: String = "-", val namedAggregate: NamedAggregate, val messageFlux: Flux<StateEventExchange<*>>, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, val eventHandler: EventHandler, val scheduler: Scheduler, messageReadiness: Mono<Void> = Mono.empty(), processingAdmission: () -> Unit = {}, processingQuiescence: () -> Unit = {}, metrics: WowMetrics = WowMetrics.NONE) : AbstractAggregateEventDispatcher<StateEventExchange<*>>

Dispatcher for processing state events within a specific aggregate context.

This class handles the distribution and processing of state events for a particular named aggregate. It extends AbstractAggregateEventDispatcher to provide concrete implementation for state event processing, including access to aggregate state.

Parameters

messageReadiness

Completion of asynchronous message-source setup when this dispatcher is registered directly with a runtime

processingAdmission

Explicit transport-processing gate opened by start

processingQuiescence

Logical transport gate closed by quiesce

metrics

Instance-scoped metrics recorder for dispatcher operations

Constructors

AggregateStateEventDispatcher

constructor(name: String = "-", namedAggregate: NamedAggregate, messageFlux: Flux<StateEventExchange<*>>, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, eventHandler: EventHandler, scheduler: Scheduler, messageReadiness: Mono<Void> = Mono.empty(), processingAdmission: () -> Unit = {}, processingQuiescence: () -> Unit = {}, metrics: WowMetrics = WowMetrics.NONE)

Creates a new AggregateStateEventDispatcher with the specified parameters