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

MonoMessageProcessor

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

A message processor that returns a Mono result.

This is a specialized reactive processor for single-value asynchronous results.

Parameters

P

The type of the processor instance

M

The type of message exchange being processed

R

The Mono type result

Inheritors

AggregateProcessor

Properties

abstract val contextName: String

abstract val processorName: String

Functions

getContextAlias

fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String

getContextAliasPrefix

fun NamedBoundedContext.getContextAliasPrefix(): String

Gets the context alias prefix for this bounded context.

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

abstract fun process(exchange: M): R

Processes the given message exchange and returns a result.