Source Runtime Environment

As outlined in the environment introduction the source runtime environment differs from the other ones. It does not listen to an internal message queue for incoming items it simply forwards to the assigned component but it establishes itself a connection with an external data source.

Therefore it does not provide a loop where it listens for incoming messages but executes the source component inside a dedicated thread passing on itself as callback for handling messages received from the attached external data sink.

On an incoming message the attached source forwards the item to the callback

IncomingMessageCallback#onMessage(StreamingDataMessage)

which in turn simply inserts it into the assigned queue.

For more information, please see the source code.