Package-level declarations
Types
Enumeration of the different kinds of first parameters that message functions can accept.
Metadata describing a message function's properties and access patterns.
Parser for extracting function metadata from Kotlin reflection.
A message function accessor for functions with injectable parameters.
Represents a parameter that can be injected into a message function.
Error handler that logs errors and resumes with an empty Mono.
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.
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.
Registry for message functions that can be registered and queried.
A simple message function accessor for functions without injectable parameters.
Simple implementation of MessageFunctionRegistrar using a thread-safe set.
Functions
Extension function to log errors and resume with empty Mono.
Converts FunctionAccessorMetadata to a MessageFunctionAccessor. Creates either a SimpleMessageFunctionAccessor or InjectableMessageFunctionAccessor based on whether the function has injectable parameters.