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 = {})
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