wow-core/me.ahoo.wow.messaging.processor/MonoMessageProcessor

MonoMessageProcessor

interface MonoMessageProcessor<P : Any, M : MessageExchange<*, *>, out R : Mono<*>> : ReactiveMessageProcessor<P, M, R>

Inheritors

Properties

Link copied to clipboard
abstract val contextName: String
Link copied to clipboard
abstract val processorName: String

Functions

Link copied to clipboard
fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String
Link copied to clipboard
Link copied to clipboard
abstract fun process(exchange: M): R