5.11.4

wow-core/me.ahoo.wow.modeling.command/AbstractCommandFunction

AbstractCommandFunction

abstract class AbstractCommandFunction<C : Any>(val commandAggregate: CommandAggregate<C, *>, afterCommandFunctions: List<AfterCommandFunction<C>>) : MessageFunction<C, ServerCommandExchange<*>, Mono<DomainEventStream>>

Inheritors

CommandFunction

DefaultDeleteAggregateFunction

DefaultRecoverAggregateFunction

Constructors

AbstractCommandFunction

constructor(commandAggregate: CommandAggregate<C, *>, afterCommandFunctions: List<AfterCommandFunction<C>>)

Properties

commandAggregate

val commandAggregate: CommandAggregate<C, *>

abstract val contextName: String

abstract val functionKind: FunctionKind

abstract override val name: String

abstract val processor: C

open override val processorName: String

open override val qualifiedName: String

The fully qualified name of the function.

supportedTopics

abstract val supportedTopics: Set<NamedAggregate>

abstract val supportedType: Class<*>

Message body types supported by the message function.

Functions

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

getContextAlias

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

getContextAliasPrefix

fun NamedBoundedContext.getContextAliasPrefix(): String

open fun handle(exchange: ServerCommandExchange<*>): Mono<DomainEventStream>

open operator override fun invoke(exchange: ServerCommandExchange<*>): Mono<DomainEventStream>

abstract fun invokeCommand(exchange: ServerCommandExchange<*>): Mono<*>

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

open fun isSameFunction(functionInfo: FunctionInfo): Boolean

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

fun FunctionInfo.toWaitSignal(id: String, 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(), signalTime: Long = System.currentTimeMillis()): WaitSignal