Package-level declarations
Types
Link copied to clipboard
class MessageAnnotationFunctionCondition(onMessageAnnotations: KClass<out Annotation>) : Function1<KFunction<*>, Boolean>
Link copied to clipboard
Link copied to clipboard
interface MonoMessageProcessor<P : Any, M : MessageExchange<*, *>, out R : Mono<*>> : ReactiveMessageProcessor<P, M, R>
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
Link copied to clipboard
open class ProcessorMetadataParser<E : MessageExchange<*, *>>(functionCondition: (KFunction<*>) -> Boolean = { true }) : CacheableMetadataParser
Link copied to clipboard
interface ReactiveMessageProcessor<P : Any, M : MessageExchange<*, *>, out R : Publisher<*>> : MessageProcessor<P, M, R>