wow-core/me.ahoo.wow.eventsourcing.snapshot/SnapshotDispatcher

SnapshotDispatcher

class SnapshotDispatcher(    val name: String,     val namedAggregates: Set<NamedAggregate> = MetadataSearcher.namedAggregateType.keys.toSet(),     snapshotHandler: SnapshotHandler,     stateEventBus: StateEventBus,     parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM,     schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier(SNAPSHOT_PROCESSOR_NAME)) : AbstractDispatcher<StateEventExchange<*>> , MessageDispatcher

Constructors

Link copied to clipboard
constructor(    name: String,     namedAggregates: Set<NamedAggregate> = MetadataSearcher.namedAggregateType.keys.toSet(),     snapshotHandler: SnapshotHandler,     stateEventBus: StateEventBus,     parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM,     schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier(SNAPSHOT_PROCESSOR_NAME))

Properties

Link copied to clipboard
open override val name: String

named like applicationName.SnapshotDispatcher

Link copied to clipboard

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
open override fun newAggregateDispatcher(namedAggregate: NamedAggregate, messageFlux: Flux<StateEventExchange<*>>): MessageDispatcher
Link copied to clipboard
open override fun receiveMessage(namedAggregate: NamedAggregate): Flux<StateEventExchange<*>>
Link copied to clipboard
open override fun run()