Source

Source components establish connections with data sources no matter if these provide access to streaming or static data. It depends on the developer how data is read from a source and gets converted into single messages which are provided to the pipeline for further processing.

Each implementation of this type must follow the source interface. Compared to other components, eg. operator or emitter, it only provides a method for assigning a callback for incoming messages. The callback provides an onMessage method that must be executed for each new message.

Tutorial

To learn more on how to implement your own SPQR source component, follow this tutorial.