MessageProcessor

Base interface for message processors that handle message exchanges.

Message processors are responsible for processing messages and producing results. They can be synchronous or reactive depending on the result type.

The type of the processor instance

The type of message exchange being processed

The type of result produced by processing

Properties

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

Gets the context alias prefix for this bounded context.

abstract fun process(exchange: M): R

Processes the given message exchange and returns a result.