support new stream sources

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