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<*>>
Dispatcher for projections that handles domain events and coordinates projection processing. This dispatcher extends AbstractEventDispatcher to provide event-driven processing for projections that transform domain events into read models or perform side effects.
Constructors
Link copied to clipboard
constructor(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: ProjectionFunctionRegistrar, eventHandler: ProjectionHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("ProjectionDispatcher"))
Properties
Link copied to clipboard
The bus for publishing domain events.
Link copied to clipboard
The handler for processing domain events.
Link copied to clipboard
The registrar for projection functions.
Link copied to clipboard
The number of parallel threads for processing messages (default: MessageParallelism.DEFAULT_PARALLELISM).
Link copied to clipboard
The bus for publishing state events.