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 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 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 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.