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

StatelessSagaFunction

class StatelessSagaFunction(val delegate: MessageFunction<Any, DomainEventExchange<*>, Mono<*>>, commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, messagePropagator: MessagePropagators = MessagePropagators.DEFAULT) : MessageFunction<Any, DomainEventExchange<*>, Mono<CommandStream>> , Decorator<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

A stateless saga function that processes domain events and generates command streams. This function wraps a delegate message function and extends its behavior to handle command execution and collection into a CommandStream for stateless saga processing.

Parameters

delegate

The underlying message function that handles the domain event processing.

commandGateway

The gateway used to send commands.

commandMessageFactory

The factory for creating command messages.

messagePropagator

Propagates the event's context into the commands this saga function sends, with this function as their producer: a chain wait reaches only the commands of the saga function it waits for.

Constructors

StatelessSagaFunction

constructor(delegate: MessageFunction<Any, DomainEventExchange<*>, Mono<*>>, commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory, messagePropagator: MessagePropagators = MessagePropagators.DEFAULT)

Properties

contextName

open override val contextName: String

delegate

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

functionKind

open override val functionKind: FunctionKind

name

open override val name: String

processor

open override val processor: Any

The processor instance that contains the actual business logic for handling messages.

supportedTopics

open override val supportedTopics: Set<NamedAggregate>

The set of named aggregates (topics) that this function supports. The function will only process messages that match one of these aggregates.

supportedType

open override val supportedType: Class<*>

The class type of message bodies that this function can process. Used to determine if a message is supported by checking if the message body is an instance of this type.

Functions

getAnnotation

open override fun <A : Annotation> getAnnotation(annotationClass: Class<A>): A?

Retrieves an annotation of the specified type from the function's metadata.

invoke

open operator override fun invoke(exchange: DomainEventExchange<*>): Mono<CommandStream>

Invokes the message function with the given exchange. This is the primary method to execute the function's logic.

toString

open override fun toString(): String