Package-level declarations
Types
Link copied to clipboard
class DefaultProjectionHandler(chain: FilterChain<DomainEventExchange<*>>, errorHandler: ErrorHandler<DomainEventExchange<*>> = LogResumeErrorHandler()) : AbstractHandler<DomainEventExchange<*>> , ProjectionHandler
Link copied to clipboard
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<*>>
Link copied to clipboard
Link copied to clipboard
class ProjectionFunctionRegistrar(actual: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar()) : AbstractEventFunctionRegistrar
Link copied to clipboard