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

AbstractEventDispatcher

abstract class AbstractEventDispatcher<E : MessageExchange<*, *>, BUS : MessageBus<*, E>>(metrics: WowMetrics) : MainDispatcher<E>

Inheritors

EventStreamDispatcher

StateEventDispatcher

Constructors

AbstractEventDispatcher

constructor(metrics: WowMetrics)

Properties

abstract val eventHandler: EventHandler

The event handler for processing events.

functionRegistrar

abstract val functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

The registrar containing event processing functions.

abstract val messageBus: BUS

The message bus for sending and receiving events.

namedAggregates

open override val namedAggregates: Set<NamedAggregate>

The set of named aggregates that this dispatcher will manage.

abstract val parallelism: Int

The level of parallelism for processing events.

schedulerSupplier

abstract val schedulerSupplier: AggregateSchedulerSupplier

Functions

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

Creates a flux of messages for the specified subscription.