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

Constructors

StatelessSagaFunction

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

Properties

open override val contextName: String

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

open override val functionKind: FunctionKind

open override val name: String

open override val processor: Any

open override val processorName: String

open override val qualifiedName: String

The fully qualified name of the function.

supportedTopics

open override val supportedTopics: Set<NamedAggregate>

open override val supportedType: Class<*>

Message body types supported by the message function.

Functions

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

getContextAlias

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

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

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

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

open fun isSameFunction(functionInfo: FunctionInfo): Boolean

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

open override fun toString(): String

fun FunctionInfo.toWaitSignal(commandId: String, stage: CommandStage, isLastProjection: Boolean = false, errorCode: String = ErrorCodes.SUCCEEDED, errorMsg: String = ErrorCodes.SUCCEEDED_MESSAGE, bindingErrors: List<BindingError> = emptyList(), result: Map<String, Any> = emptyMap()): WaitSignal