Hi all
This email is for all those who are currently using the JMS Input/Output operators in malhar (com.datatorrent.lib.io.jms.AbstractJMSInputOperator<T> subclasses or com.datatorrent.lib.io.jms.AbstractJMSOutputOperator subclasses). I am planning to make the following changes in JMSBase (the base class for all JMS operators) that will introduce backward incompatibility as follows: - connectionFactoryClass will be removed and instead a “ConnectionFactoryBuilder” abstraction will be provided that allows the caller to supply this builder which will instantiate the JMS connection factory. This makes it easy to abstract out things like credentials for some of the newer message brokers like SQS that we want to support. - The current default functionality (i.e. corresponding to org.apache.activemq.ActiveMQConnectionFactory) will be refactored into a default ConnectionFactoryBuilder implementation that is set in the JMSBase constructor. - The deprecated convenience methods such as com.datatorrent.lib.io.jms.JMSBase.setUser/setPassword/setUrl will be removed and as indicated the caller will have to use connectionFactoryProperties to set these values. Please provide your feedback as soon as possible. Thanks Sanjay
