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

ReactiveMessageProcessor

interface ReactiveMessageProcessor<P : Any, M : MessageExchange<*, *>, out R : Publisher<*>> : MessageProcessor<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