wow-core/me.ahoo.wow.event/AbstractEventDispatcher

AbstractEventDispatcher

abstract class AbstractEventDispatcher<R : Mono<*>> : MessageDispatcher

Inheritors

DomainEventDispatcher

ProjectionDispatcher

StatelessSagaDispatcher

Constructors

AbstractEventDispatcher

constructor()

Types

object Companion

DomainEventDistributionSubscriber

inner class DomainEventDistributionSubscriber : SafeSubscriber<GroupedFlux<MaterializedNamedAggregate, EventStreamExchange>>

StateEventDistributionSubscriber

inner class StateEventDistributionSubscriber : SafeSubscriber<GroupedFlux<MaterializedNamedAggregate, StateEventExchange<*>>>

Properties

abstract val domainEventBus: DomainEventBus

abstract val eventHandler: EventHandler

functionRegistrar

abstract val functionRegistrar: AbstractEventFunctionRegistrar

abstract val name: String

abstract val parallelism: Int

abstract val stateEventBus: StateEventBus

Functions

open override fun close()

open override fun run()