support new stream sources

Add support for more types of source processors:

* RabbitMQ
* Redis
* SQS
* Kinesis
* Websocket