wow-core/me.ahoo.wow.saga.stateless/StatelessSagaFunctionRegistrar

StatelessSagaFunctionRegistrar

class StatelessSagaFunctionRegistrar(commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, actual: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>> = SimpleMessageFunctionRegistrar()) : AbstractEventFunctionRegistrar

Registrar for stateless saga functions that creates StatelessSagaFunction instances from processors annotated with saga metadata.

Constructors

constructor(commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, 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 saga metadata and creating stateless saga functions. This method parses the processor's class for saga annotations and wraps the resulting message functions with StatelessSagaFunction to handle command execution.

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.