A structured streaming source for Spark to read data from a streaming source. Currently supports only ActiveMQ