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

AbstractDispatcher

abstract class AbstractDispatcher<T : Any> : MessageDispatcher

Abstract base class for message dispatchers that manage multiple aggregate dispatchers.

This class coordinates the dispatching of messages to multiple named aggregates by creating individual dispatchers for each aggregate and managing their lifecycle.

Parameters

The type of message being dispatched

Inheritors

SnapshotDispatcher

CommandDispatcher

Constructors

AbstractDispatcher

constructor()

Types

Companion

object Companion

Properties

name

abstract val name: String

namedAggregates

abstract val namedAggregates: Set<NamedAggregate>

must be me.ahoo.wow.modeling.MaterializedNamedAggregate

Functions

open override fun close()

Closes the dispatcher and all its aggregate dispatchers.

newAggregateDispatcher

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

Creates a new message dispatcher for a specific named aggregate.

receiveMessage

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

Creates a flux of messages for the specified named aggregate.

run

open override fun run()

Starts the dispatcher by running all aggregate dispatchers.