AggregateSnapshotDispatcher
constructor(name: String = "-", namedAggregate: NamedAggregate, messageFlux: Flux<StateEventExchange<*>>, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, snapshotHandler: SnapshotHandler, scheduler: Scheduler)
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