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

FunctionAccessorMetadata

data class FunctionAccessorMetadata<P, out R>(val functionKind: FunctionKind, val accessor: FunctionAccessor<P, R>, val supportedType: Class<*>, val supportedTopics: Set<NamedAggregate>, val firstParameterKind: FirstParameterKind, val injectParameters: Array<InjectParameter>) : FunctionInfo, NamedBoundedContext

Metadata describing a message function's properties and access patterns.

Contains all the information needed to invoke a message function reflectively, including supported types, topics, parameter kinds, and injection requirements.

Parameters

The processor type

The return type

Constructors

FunctionAccessorMetadata

constructor(functionKind: FunctionKind, accessor: FunctionAccessor<P, R>, supportedType: Class<*>, supportedTopics: Set<NamedAggregate>, firstParameterKind: FirstParameterKind, injectParameters: Array<InjectParameter>)

Properties

accessor

val accessor: FunctionAccessor<P, R>

The function accessor for invocation

contextName

open override val contextName: String

The bounded context name that this function belongs to.

firstParameterKind

val firstParameterKind: FirstParameterKind

How the first parameter should be extracted

functionKind

open override val functionKind: FunctionKind

The kind of function (COMMAND, EVENT, etc.)

injectParameterLength

val injectParameterLength: Int

The number of injectable parameters.

injectParameters

val injectParameters: Array<InjectParameter>

Array of parameters that need dependency injection

name

open override val name: String

The name of the function/method.

processorName

open override val processorName: String

The name of the processor class.

processorType

val processorType: Class<P>

The class of the processor.

supportedTopics

val supportedTopics: Set<NamedAggregate>

The set of supported named aggregates

supportedType

val supportedType: Class<*>

The class of supported message bodies

Functions

equals

open operator override fun equals(other: Any?): Boolean

Checks equality based on the accessor, since that's the unique identifier.

extractFirstArgument

fun extractFirstArgument(exchange: MessageExchange<*, *>): Any

Extracts the first argument for function invocation based on the parameter kind.

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.

hashCode

open override fun hashCode(): Int

Returns hash code based on the accessor.

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.

toAfterCommandFunctionMetadata

fun <C : Any> FunctionAccessorMetadata<C, Mono<*>>.toAfterCommandFunctionMetadata(): AfterCommandFunctionMetadata<C>

Converts a function accessor metadata into after-command function metadata.

toMessageFunction

fun <P : Any, M : MessageExchange<*, *>, R> FunctionAccessorMetadata<P, R>.toMessageFunction(processor: P): MessageFunctionAccessor<P, M, R>

Converts FunctionAccessorMetadata to a MessageFunctionAccessor. Creates either a SimpleMessageFunctionAccessor or InjectableMessageFunctionAccessor based on whether the function has injectable parameters.

toString

open override fun toString(): String

Returns a string representation of this metadata.

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