Package-level declarations
Types
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
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, metrics: WowMetrics = WowMetrics.NONE) : 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(), failureRecorder: FailureRecorder = FailureRecorder.NONE, ackOnUnrecordedFailure: Boolean = true, metrics: WowMetrics = WowMetrics.NONE) : FailureRecordingHandler<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"), metrics: WowMetrics = WowMetrics.NONE) : 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.