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

DomainEventDispatcher

class DomainEventDispatcher(val name: String, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val domainEventBus: DomainEventBus, val stateEventBus: StateEventBus, val functionRegistrar: DomainEventFunctionRegistrar, val eventHandler: DomainEventHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("EventDispatcher")) : AbstractEventDispatcher<Mono<*>>

Constructors

DomainEventDispatcher

constructor(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: DomainEventFunctionRegistrar, eventHandler: DomainEventHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("EventDispatcher"))

Properties

open override val domainEventBus: DomainEventBus

open override val eventHandler: DomainEventHandler

functionRegistrar

open override val functionRegistrar: DomainEventFunctionRegistrar

open override val name: String

named like applicationName.DomainEventDispatcher

open override val parallelism: Int

open override val stateEventBus: StateEventBus

Functions

open override fun close()

open override fun run()