wow-core/me.ahoo.wow.eventsourcing.snapshot.dispatcher/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), metrics: WowMetrics = WowMetrics.NONE) : MainDispatcher<StateEventExchange<*>>

Constructors

SnapshotDispatcher

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), metrics: WowMetrics = WowMetrics.NONE)

Properties

name

open override val name: String

named like applicationName.SnapshotDispatcher

namedAggregates

open override val namedAggregates: Set<NamedAggregate>

The set of named aggregates that this dispatcher will manage.

Functions

newAggregateDispatcher

open override fun newAggregateDispatcher(namedAggregate: NamedAggregate, messageFlux: Flux<StateEventExchange<*>>): MessageDispatcher

Creates a new message dispatcher for a specific named aggregate.

receiveMessage

open override fun receiveMessage(subscription: MessageSubscription): Flux<StateEventExchange<*>>

Creates a flux of messages for the specified subscription.