Reliable receiver for Spark streaming from any JMS 1.1 source. Use net.tbfe.spark.streaming.jms.JmsStreamUtils to create InputDStream
Should be used if JMS provider supports and individual acknowledge mode. This is not part of the JMS standard but is supported by some providers. Also can be used if you don't need need reliable receiver with Session.AUTO_ACKNOWLEDGE mode.
Should be used if you require reliable receiver and JMS provider does not support a individual acknowledge mode.
-
Setup Queue/Topic and connection factory in JNDI properties. This is JMS provider specific
-
Create instance of JndiMessageConsumerFactory.
-
Create JmsDestinationInfo which has and for Queue and an implementation for Topic
-
Use one of the methods of JmsStreamUtils to create InputDStream
If not using JNDI then and implementation of MessageConsumerFactory needs to be created