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

AggregateEventDispatcher

class AggregateEventDispatcher(val name: String = "-", val namedAggregate: NamedAggregate, val messageFlux: Flux<EventStreamExchange>, 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<EventStreamExchange>

Dispatcher for processing domain events within a specific aggregate context.

This class handles the distribution and processing of domain event streams for a particular named aggregate. It extends AbstractAggregateEventDispatcher to provide concrete implementation for event stream processing.

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

AggregateEventDispatcher

constructor(name: String = "-", namedAggregate: NamedAggregate, messageFlux: Flux<EventStreamExchange>, 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 AggregateEventDispatcher with the specified parameters