wow-core/me.ahoo.wow.eventsourcing.snapshot.dispatcher/AggregateSnapshotDispatcher

AggregateSnapshotDispatcher

class AggregateSnapshotDispatcher(val name: String = "-", val namedAggregate: NamedAggregate, val messageFlux: Flux<StateEventExchange<*>>, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, snapshotHandler: SnapshotHandler, val scheduler: Scheduler, messageReadiness: Mono<Void> = Mono.empty(), processingAdmission: () -> Unit = {}, processingQuiescence: () -> Unit = {}, metrics: WowMetrics = WowMetrics.NONE) : AggregateDispatcher<StateEventExchange<*>> , ProcessorInfo

Dispatcher for handling snapshot operations on state events for a specific aggregate. Routes state event exchanges to the snapshot handler for processing.

Parameters

name

the name of this dispatcher (default: aggregateName-AggregateSnapshotDispatcher)

namedAggregate

the named aggregate this dispatcher handles

messageFlux

the flux of state event exchanges to process

parallelism

the number of parallel processing groups (default: MessageParallelism.DEFAULT_PARALLELISM)

snapshotHandler

the handler responsible for creating and storing snapshots

scheduler

the scheduler for processing messages

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

AggregateSnapshotDispatcher

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