Spark to subscribe to ActiveMQ or Mosquitto MQTT broker -

i want subscribe spark activemq or mosquitto mqtt broker. how can that?

a more recent pull request , code mqtt adapter spark streaming in apache incubator-spark repository here https://github.com/apache/incubator-spark/pull/64