tbfenet/spark-jms-receiver

spark-jms-receiver's Issues

Passing user credentials

Successfully implemented receiver client code using
val msgs = JmsStreamUtils.createSynchronousJmsQueueStream(ssc, MQConsumerFactory(host, port.toInt, qm, qn, user, credentials),
converter,
1000,
1.second,
10.seconds,
StorageLevel.MEMORY_AND_DISK_SER
)
Here, the user and credentials passing are blank. For an authorization enabled MQ cluster, passing user name and password is returning AUTHORIZATION ERROR for the specific queue manager and queue name. Here passing the username and password as plain text. Please advise.

And, is there a way I can pass MQ channel to the ConsumerFactory? Currently the queue manager and queue name are being passed to this.

Question?

I will like to contribute by giving details of an instruction on how to connect to jms/ActiveMQ with an example as the details are not specified for a newbie like myself.

Wondering if I can help with writing this up.

Thanks,
Adam

Commit privilege and Spark package maintenance

I recently received an email asking for usage examples and for support for another version of Spark (1.4.1). It would probably be good to support 1.4.x, 1.6.x, and 2.0.x as these are the common versions right now. I would also like to contribute usage examples.

I'm sure you've got a lot on your plate. Is there a way you could give me commit privileges for this repo, and some way to update the spark package? Then we can get these changes in quickly.