Package-level declarations
Types
Link copied to clipboard
abstract class AbstractAggregateEventDispatcher<E : MessageExchange<*, DomainEventStream>> : AggregateDispatcher<E>
Abstract base class for aggregate event dispatchers.
Link copied to clipboard
abstract class AbstractEventDispatcher<E : MessageExchange<*, *>, BUS : MessageBus<*, E>> : MainDispatcher<E>
Link copied to clipboard
abstract class AbstractEventFunctionRegistrar(val delegate: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar()) : MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> , Decorator<MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>>
Abstract base class for event function registrars.
Link copied to clipboard
class AggregateEventDispatcher(val name: String = "-", val namedAggregate: NamedAggregate, val messageFlux: Flux<EventStreamExchange>, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, val eventHandler: EventHandler, val scheduler: Scheduler) : AbstractAggregateEventDispatcher<EventStreamExchange>
Dispatcher for processing domain events within a specific aggregate context.
Link copied to clipboard
class AggregateStateEventDispatcher(val name: String = "-", val namedAggregate: NamedAggregate, val messageFlux: Flux<StateEventExchange<*>>, val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, val eventHandler: EventHandler, val scheduler: Scheduler) : AbstractAggregateEventDispatcher<StateEventExchange<*>>
Dispatcher for processing state events within a specific aggregate context.
Link copied to clipboard
open class CompositeEventDispatcher(val name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, eventHandler: EventHandler, schedulerSupplier: AggregateSchedulerSupplier) : MessageDispatcher
A composite event dispatcher that combines event stream and state event dispatchers to handle domain events and state events efficiently.
Link copied to clipboard
class DefaultDomainEventHandler(chain: FilterChain<DomainEventExchange<*>>, errorHandler: ErrorHandler<DomainEventExchange<*>> = LogResumeErrorHandler()) : AbstractHandler<DomainEventExchange<*>> , DomainEventHandler
Default implementation of DomainEventHandler.
Link copied to clipboard
class DomainEventDispatcher(name: String, parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, domainEventBus: DomainEventBus, stateEventBus: StateEventBus, functionRegistrar: DomainEventFunctionRegistrar, eventHandler: DomainEventHandler, schedulerSupplier: AggregateSchedulerSupplier = DefaultAggregateSchedulerSupplier("EventDispatcher")) : CompositeEventDispatcher
Domain Event Dispatcher responsible for coordinating the processing of domain events.
Link copied to clipboard
open class DomainEventFunctionFilter(serviceProvider: ServiceProvider) : ExchangeFilter<DomainEventExchange<*>>
Filter for processing domain events through registered event functions.
Link copied to clipboard
class DomainEventFunctionRegistrar(actual: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar()) : AbstractEventFunctionRegistrar
Registrar for domain event processing functions.
Link copied to clipboard
Interface for domain event handlers.
Link copied to clipboard
Base interface for event handlers that process domain event exchanges.
Link copied to clipboard
class EventStreamDispatcher(val name: String, val parallelism: Int, val messageBus: DomainEventBus, val functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, val eventHandler: EventHandler, val schedulerSupplier: AggregateSchedulerSupplier) : AbstractEventDispatcher<EventStreamExchange, DomainEventBus>
Link copied to clipboard
class StateEventDispatcher(val name: String, val parallelism: Int, val messageBus: StateEventBus, val functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, val eventHandler: EventHandler, val schedulerSupplier: AggregateSchedulerSupplier) : AbstractEventDispatcher<StateEventExchange<*>, StateEventBus>