AfterCommandFunction

Constructors

Link copied to clipboard
constructor(metadata: AfterCommandFunctionMetadata<C>, delegate: MessageFunction<C, ServerCommandExchange<*>, Mono<*>>)

Properties

Link copied to clipboard
open override val contextName: String
Link copied to clipboard
open override val delegate: MessageFunction<C, ServerCommandExchange<*>, Mono<*>>
Link copied to clipboard
open override val functionKind: FunctionKind
Link copied to clipboard
Link copied to clipboard
open override val name: String
Link copied to clipboard
open override val order: Order
Link copied to clipboard
open override val processor: C
Link copied to clipboard
open override val processorName: String
Link copied to clipboard
open override val qualifiedName: String

The fully qualified name of the function.

Link copied to clipboard
open override val supportedTopics: Set<NamedAggregate>
Link copied to clipboard
open override val supportedType: Class<*>

Message body types supported by the message function.

Functions

Link copied to clipboard
open override fun <A : Annotation> getAnnotation(annotationClass: Class<A>): A?
Link copied to clipboard
fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String
Link copied to clipboard
open override fun handle(exchange: ServerCommandExchange<*>): Mono<*>
Link copied to clipboard
open operator override fun invoke(exchange: ServerCommandExchange<*>): Mono<*>
Link copied to clipboard
Link copied to clipboard
open override fun isSameFunction(functionInfo: FunctionInfo): Boolean
Link copied to clipboard
open override fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportMessage(message: M): Boolean
Link copied to clipboard
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