Implement Reliable spark streaming receiver

The spark streaming message bus receiver isn't reliable yet. The receiver needs to handle data loss in case of worker node that has it running.

We currently handle the driver failure automatically by re-deploying spark streaming module. But, this is about the data loss when the worker node dies.

Please see the documents here:

https://databricks.com/blog/2015/01/15/improved-driver-fault-tolerance-and-zero-data-loss-in-spark-streaming.html

http://spark.apache.org/docs/latest/streaming-custom-receivers.html