AbstractEventFunctionRegistrar
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.
This class provides a foundation for registering event processing functions. It delegates to a MessageFunctionRegistrar and provides methods to register processors, either directly as MessageFunction instances or by resolving them from annotated classes.
See also
Inheritors
Constructors
Link copied to clipboard
constructor(delegate: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar())
Properties
Link copied to clipboard
open override val delegate: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>
The underlying message function registrar (default: SimpleMessageFunctionRegistrar)
Link copied to clipboard
The set of all registered functions.
Functions
Link copied to clipboard
Registers a message function.
Link copied to clipboard
Registers an event processor.
Link copied to clipboard
abstract fun resolveProcessor(processor: Any): Set<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>
Resolves a processor object into a set of message functions.
Link copied to clipboard
open override fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportedFunctions(message: M): Sequence<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>
Finds all functions that support processing the given message.
Link copied to clipboard
Unregisters a message function.