AggregateSnapshotDispatcher
constructor(snapshotHandler: SnapshotHandler, namedAggregate: NamedAggregate, name: String = "-", parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, scheduler: Scheduler, messageFlux: Flux<StateEventExchange<*>>)
Parameters
snapshotHandler
the handler responsible for creating and storing snapshots
namedAggregate
the named aggregate this dispatcher handles
name
the name of this dispatcher (default: aggregateName-AggregateSnapshotDispatcher)
parallelism
the number of parallel processing groups (default: MessageParallelism.DEFAULT_PARALLELISM)
scheduler
the scheduler for processing messages
messageFlux
the flux of state event exchanges to process