create JavaDStream<T> from any stream using custom receiver.Here is the Example for RabbitMq supporting Spark Streaming.