messageFlux

The flux of message exchanges to be processed.

This reactive stream provides the source of messages that the dispatcher will handle. The flux is grouped by key and processed in parallel according to the configured parallelism level.

The flux should emit MessageExchange instances that can be processed by the handleExchange() method implementation.