wow-core/me.ahoo.wow.event.dispatcher/DomainEventFunctionRegistrar

DomainEventFunctionRegistrar

class DomainEventFunctionRegistrar(actual: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar()) : AbstractEventFunctionRegistrar

Registrar for domain event processing functions.

This class extends AbstractEventFunctionRegistrar to provide domain event specific function registration. It resolves processors by analyzing their annotations and creating message functions for event handling.

Parameters

actual

The underlying message function registrar (default: SimpleMessageFunctionRegistrar)

Constructors

DomainEventFunctionRegistrar

constructor(actual: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar())

Properties

delegate

open override val delegate: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

The underlying message function registrar (default: SimpleMessageFunctionRegistrar)

functions

open override val functions: Set<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

The immutable set of all currently registered functions.

Functions

filter

open override fun filter(predicate: (MessageFunction<Any, DomainEventExchange<*>, Mono<*>>) -> Boolean): MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

Creates a filtered view of this registrar.

open override fun register(function: MessageFunction<Any, DomainEventExchange<*>, Mono<*>>)

Registers a message function with this registrar.

registerProcessor

fun registerProcessor(processor: Any)

Registers an event processor.

resolveProcessor

open override fun resolveProcessor(processor: Any): Set<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

Resolves a processor into domain event message functions.

supportedFunctions

open override fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportedFunctions(message: M): Sequence<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

Finds all registered functions that support processing the given message.

unregister

open override fun unregister(function: MessageFunction<Any, DomainEventExchange<*>, Mono<*>>)

Unregisters a message function from this registrar.

DomainEventFunctionRegistrar

Parameters

See also

Constructors

Properties

Functions