wow-core/me.ahoo.wow.messaging.function/MessageFunctionAccessor

MessageFunctionAccessor

interface MessageFunctionAccessor<P : Any, in M : MessageExchange<*, *>, out R> : MessageFunction<P, M, R>

An accessor-based implementation of MessageFunction that uses metadata to provide function information. This interface extends MessageFunction and provides implementations for various properties and methods by delegating to the underlying metadata.

Parameters

the type of the processor

the type of the message exchange, contravariant

the return type of the function

Inheritors

SimpleMessageFunctionAccessor

InjectableMessageFunctionAccessor

Properties

contextName

open override val contextName: String

The name of the bounded context, obtained from the metadata.

functionKind

open override val functionKind: FunctionKind

The kind of the function (e.g., command, event), obtained from the metadata.

metadata

abstract val metadata: FunctionAccessorMetadata<P, R>

The metadata containing information about the function, such as supported types, topics, and accessor details.

name

open override val name: String

The name of the function, obtained from the metadata.

processor

abstract val processor: P

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

processorName

open override val processorName: String

The name of the processor, obtained from the metadata.

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 supported topics, obtained from the metadata.

supportedType

open override val supportedType: Class<*>

The supported message body type, obtained from the metadata.

Functions

getAnnotation

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

Retrieves an annotation from the function's accessor using reflection.

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: M): R

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

invoke

abstract operator fun invoke(exchange: M): R

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.

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