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

Constructors

FunctionAccessorMetadata

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

Properties

val accessor: FunctionAccessor<P, R>

open override val contextName: String

firstParameterKind

val firstParameterKind: FirstParameterKind

open override val functionKind: FunctionKind

injectParameterLength

val injectParameterLength: Int

injectParameters

val injectParameters: Array<InjectParameter>

open override val name: String

open override val processorName: String

val processorType: Class<P>

supportedTopics

val supportedTopics: Set<NamedAggregate>

val supportedType: Class<*>

Functions

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

extractFirstArgument

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

getContextAlias

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

open override fun hashCode(): Int

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

open fun isSameFunction(functionInfo: FunctionInfo): Boolean

toMessageFunction

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

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