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

ReactiveMessageProcessor

interface ReactiveMessageProcessor<P : Any, M : MessageExchange<*, *>, out R : Publisher<*>> : MessageProcessor<P, M, R>

A reactive message processor that returns a Publisher result.

This interface extends MessageProcessor for processors that return reactive streams.

Parameters

P

The type of the processor instance

M

The type of message exchange being processed

R

The Publisher type result

Inheritors

MonoMessageProcessor

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.