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

Package-level declarations

Types

enum FirstParameterKind : Enum<FirstParameterKind>

Enumeration of the different kinds of first parameters that message functions can accept.

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.

InjectParameter

@InternalWowApi

data class InjectParameter(val parameter: KParameter)

Represents a parameter that can be injected into a message function.

MessageFunction

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

Represents a message function that processes messages within a message exchange. This interface defines the contract for functions that can handle specific message types and topics, providing a way to invoke processing logic on message exchanges.

MessageFunctionRegistrar

@InternalWowApi

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

Registry for message functions that can be registered and queried.

SimpleMessageFunctionRegistrar

@InternalWowApi

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

Simple implementation of MessageFunctionRegistrar using a thread-safe set.