wow-core/me.ahoo.wow.projection/ProjectionFunctionRegistrar

ProjectionFunctionRegistrar

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

Registrar for projection functions that creates message functions from processors annotated with projection metadata.

Constructors

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 set of all registered functions.

Functions

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

Registers a message function.

registerProcessor

fun registerProcessor(processor: Any)

Registers an event processor.

resolveProcessor

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

Resolves the processor by extracting projection metadata and creating message functions. This method parses the processor's class for projection annotations and creates corresponding message functions for event handling.

supportedFunctions

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.

unregister

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

Unregisters a message function.