wow-core/me.ahoo.wow.messaging.dispatcher/AbstractDispatcher

AbstractDispatcher

abstract class AbstractDispatcher<T : Any> : MessageDispatcher

Inheritors

SnapshotDispatcher

CommandDispatcher

Constructors

AbstractDispatcher

constructor()

Types

object Companion

Properties

abstract val name: String

namedAggregates

abstract val namedAggregates: Set<NamedAggregate>

must be me.ahoo.wow.modeling.MaterializedNamedAggregate

Functions

open override fun close()

newAggregateDispatcher

abstract fun newAggregateDispatcher(namedAggregate: NamedAggregate, messageFlux: Flux<T>): MessageDispatcher

abstract fun receiveMessage(namedAggregate: NamedAggregate): Flux<T>

open override fun run()