Direct Response Operator Runtime Environment

This environment provides a runtime for direct response operators. It listens to the attached queue for incoming messages where each new item is handed over to the assigned operator for further processing.

Compared to the emitter runtime environment or the delayed response operator runtime environment this environment awaits a response from the operator. The retrieved messages (0..n) get inserted into the attached output queue.

As waiting for new messages is required the environment is implemented as java.lang.Runnable and keeps on spinning until it is interrupted by the surrounding micro pipeline.

For more information, please see the source code.