I think you should try calling reciver api in a spark. You need to create a custom receiver
http://spark.apache.org/docs/latest/streaming-custom-receivers.html
Also check trust from tathagat das, which is the source of spark from
www.apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-and-JMS-td5371.html
If you need help with details, let me know.
source share