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

StatelessSagaFunction

class StatelessSagaFunction(val delegate: MessageFunction<Any, DomainEventExchange<*>, Mono<*>>, commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory) : 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.

Constructors

constructor(delegate: MessageFunction<Any, DomainEventExchange<*>, Mono<*>>, commandGateway: CommandGateway, commandMessageFactory: CommandMessageFactory)

Properties

contextName

open override val contextName: String

delegate

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

The underlying message function that handles the domain event processing.

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.

processorName

open override val processorName: String

The name of the processor class, derived from the simple name of the processor's class.

qualifiedName

open override val qualifiedName: String

The fully qualified name of the function, formatted as "processorName.functionName(supportedTypeSimpleName)". This provides a unique identifier for the function.

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.

getContextAlias

fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String

getContextAliasPrefix

fun NamedBoundedContext.getContextAliasPrefix(): String

Gets the context alias prefix for this bounded context.

handle

open fun handle(exchange: DomainEventExchange<*>): Mono<CommandStream>

Handles the message exchange by invoking the function. This method provides an alternative way to process the exchange.

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.

isEmpty

open fun isEmpty(): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

isSameFunction

open fun isSameFunction(functionInfo: FunctionInfo): Boolean

isWaitingForFunction

fun NamedFunctionInfo?.isWaitingForFunction(function: FunctionInfo): Boolean

Checks if a function matches the criteria specified by this NamedFunctionInfo. Used to determine if a wait strategy should be notified about a specific function execution. Returns true if all specified criteria (context, processor, name) match or are not specified.

supportMessage

open fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportMessage(message: M): Boolean

Checks if the given message is supported by this function. A message is supported if its body is an instance of the supported type and its aggregate matches one of the supported topics.

toString

open override fun toString(): String

toWaitSignal

fun FunctionInfo.toWaitSignal(id: String, waitCommandId: String, commandId: String, aggregateId: AggregateId, stage: CommandStage, isLastProjection: Boolean = false, aggregateVersion: Int? = null, errorCode: String = ErrorCodes.SUCCEEDED, errorMsg: String = ErrorCodes.SUCCEEDED_MESSAGE, bindingErrors: List<BindingError> = emptyList(), result: Map<String, Any> = emptyMap(), commands: List<String> = listOf(), signalTime: Long = System.currentTimeMillis()): WaitSignal