wow-core/me.ahoo.wow.projection/ProjectionDispatcher

ProjectionDispatcher

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

Constructors

ProjectionDispatcher

constructor(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: ProjectionFunctionRegistrar, eventHandler: ProjectionHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("ProjectionDispatcher"))

Properties

open override val domainEventBus: DomainEventBus

open override val eventHandler: ProjectionHandler

functionRegistrar

open override val functionRegistrar: ProjectionFunctionRegistrar

open override val name: String

named like applicationName.ProjectionDispatcher

open override val parallelism: Int

open override val stateEventBus: StateEventBus

Functions

open override fun close()

open override fun run()