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

Package-level declarations

Types

FirstParameterKind

enum FirstParameterKind : Enum<FirstParameterKind>

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

FunctionMetadataParser

object FunctionMetadataParser

InjectableMessageFunctionAccessor

data class InjectableMessageFunctionAccessor<P : Any, in M : MessageExchange<*, *>, out R>(val processor: P, val metadata: FunctionAccessorMetadata<P, R>) : MessageFunctionAccessor<P, M, R>

InjectParameter

data class InjectParameter(val parameter: KParameter)

LogResumeErrorMessageHandler

object LogResumeErrorMessageHandler

MessageFunction

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

MessageFunctionAccessor

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

MessageFunctionRegistrar

interface MessageFunctionRegistrar<F : MessageFunction<*, *, *>>

SimpleMessageFunctionAccessor

data class SimpleMessageFunctionAccessor<P : Any, in M : MessageExchange<*, *>, out R>(val processor: P, val metadata: FunctionAccessorMetadata<P, R>) : MessageFunctionAccessor<P, M, R>

SimpleMessageFunctionRegistrar

class SimpleMessageFunctionRegistrar<F : MessageFunction<*, *, *>> : MessageFunctionRegistrar<F>

Functions

fun <T : Any> Mono<T>.logErrorResume(): Mono<T>

toMessageFunction

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