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.
Type Parameters
P
The type of the processor instance
M
The type of message exchange being processed
R
The Publisher type result