Package-level declarations
Types
Link copied to clipboard
class MessageAnnotationFunctionCondition(onMessageAnnotations: KClass<out Annotation>) : Function1<KFunction<*>, Boolean>
Condition that checks if a function should be included based on message annotations.
Link copied to clipboard
Base interface for message processors that handle message exchanges.
Link copied to clipboard
interface MonoMessageProcessor<P : Any, M : MessageExchange<*, *>, out R : Mono<*>> : ReactiveMessageProcessor<P, M, R>
A message processor that returns a Mono result.
Link copied to clipboard
data class ProcessorMetadata<P : Any, in M : MessageExchange<*, *>>(namedBoundedContext: NamedBoundedContext, val name: String, val processorType: Class<P>, val functionRegistry: Set<FunctionAccessorMetadata<P, Mono<*>>>) : NamedBoundedContext, Named, Metadata
Metadata describing a message processor and its functions.
Link copied to clipboard
open class ProcessorMetadataParser<E : MessageExchange<*, *>>(functionCondition: (KFunction<*>) -> Boolean = { true }) : CacheableMetadataParser
Parser for extracting processor metadata from classes.
Link copied to clipboard
interface ReactiveMessageProcessor<P : Any, M : MessageExchange<*, *>, out R : Publisher<*>> : MessageProcessor<P, M, R>
A reactive message processor that returns a Publisher result.