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 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 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 functions that support processing the given message.

unregister

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

Unregisters a message function.