Delayed Response Operator Runtime Environment

This environment provides a runtime for delayed 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 direct response operator runtime environment this environment does not await any response from the operator. Instead it hands over the message to the operator and notifies the assigned delayed response operators wait strategy about the new input. The strategy decides whether the results of the operator must be retrieved and inserted into the output queue or not. If the strategy decides so, it executes the callback method implemented by the environment:

void DelayedResponseCollector#retrieveMessages()

The environment in turn fetches all results from the operator and inserts the items into the outgoing 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.