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

EventStreamDispatcher

class EventStreamDispatcher(val name: String, val parallelism: Int, val messageBus: DomainEventBus, val functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, val eventHandler: EventHandler, val schedulerSupplier: AggregateSchedulerSupplier, metrics: WowMetrics = WowMetrics.NONE) : AbstractEventDispatcher<EventStreamExchange, DomainEventBus>

Constructors

EventStreamDispatcher

constructor(name: String, parallelism: Int, messageBus: DomainEventBus, functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, eventHandler: EventHandler, schedulerSupplier: AggregateSchedulerSupplier, metrics: WowMetrics = WowMetrics.NONE)

Properties

open override val eventHandler: EventHandler

The event handler for processing events.

functionRegistrar

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

The registrar containing event processing functions.

open override val messageBus: DomainEventBus

The message bus for sending and receiving events.

open override val name: String

open override val parallelism: Int

The level of parallelism for processing events.

schedulerSupplier

open override val schedulerSupplier: AggregateSchedulerSupplier

Functions

newAggregateDispatcher

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

Creates a new message dispatcher for a specific named aggregate.