added custom JMS connection factory for inbound ebms messages

Plugins/CorvusEbMS/src/main/java/hk/hku/cecid/ebms/spa/client/jms/MessageListenerJMSClient.java

@@ -25,7 +25,6 @@
 import javax.xml.soap.SOAPException;
 import javax.xml.soap.SOAPMessage;
 
-import org.apache.activemq.ActiveMQConnectionFactory;
 
 public class MessageListenerJMSClient extends EbmsEventListener {
 
@@ -49,10 +48,7 @@ public class MessageListenerJMSClient extends EbmsEventListener {
 
 	@Override
 	public void init() {
-		connectionFactory = new ActiveMQConnectionFactory(getConnectionUrl());
-        ((ActiveMQConnectionFactory)connectionFactory).setUserName(getUsername());
-        ((ActiveMQConnectionFactory)connectionFactory).setPassword(getPassword());
-
+		connectionFactory = buildConnectionFactory();
 	}
 
 	@Override
@@ -169,6 +165,26 @@ public String getQueueName() {
 		return getParameters().getProperty("queueName");
 	}
 
+	protected ConnectionFactory buildConnectionFactory() {
+		try {
+			String connectionFactoryUrl = getConnectionUrl();
+			Class connectionFactoryClass = getConnectionFactoryClass();
+			ConnectionFactory cf = (ConnectionFactory)connectionFactoryClass.getConstructor(String.class).newInstance(new Object[]{connectionFactoryUrl});
+			return cf;
+		} catch (Exception e) {
+			e.printStackTrace();
+			return null;
+		}
+	}
+
+	protected Class getConnectionFactoryClass() throws ClassNotFoundException {
+		return Class.forName(getConnectionFactoryClassName());
+	}
+
+	protected String getConnectionFactoryClassName() {
+		return getParameters().getProperty("connectionFactory");
+	}
+
 	protected String getConnectionUrl() {
 		return getParameters().getProperty("connectionUrl");
 	}

Plugins/CorvusEbMS/src/test/java/hk/hku/cecid/ebms/spa/client/jms/MessageListenerJMSClientTest.java

@@ -59,8 +59,8 @@ public static void tearDownClass() throws Exception {
 	public void setUp() throws JMSException {
 
 		instance = spy(new MessageListenerJMSClient());
-		
-
+
+		doReturn("org.apache.activemq.ActiveMQConnectionFactory").when(instance).getConnectionFactoryClassName();
 		doReturn("vm://mdh?broker.persistent=false").when(instance).getConnectionUrl();
 		doReturn("testQueue").when(instance).getQueueName();
         doReturn(null).when(instance).getUsername();

Plugins/CorvusJMS/src/main/java/org/jentrata/spa/jms/module/JMSComponent.java

@@ -11,7 +11,6 @@
 
 import javax.jms.ConnectionFactory;
 
-import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.camel.CamelContext;
 import org.apache.camel.ConsumerTemplate;
 import org.apache.camel.Exchange;
@@ -59,17 +58,25 @@ public ConsumerTemplate getConsumer() {
     }
 
     protected ConnectionFactory buildConnectionFactory() {
-        String connectionFactoryUrl = getConnectionFactoryUrl();
-        ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(connectionFactoryUrl);
-        cf.setUserName(getUsername());
-        cf.setPassword(getPassword());
-        return cf;
+        try {
+            String connectionFactoryUrl = getConnectionFactoryUrl();
+            Class connectionFactoryClass = getConnectionFactoryClass();
+            ConnectionFactory cf = (ConnectionFactory)connectionFactoryClass.getConstructor(String.class).newInstance(new Object[]{connectionFactoryUrl});
+            return cf;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
     }
-
+
+    protected Class getConnectionFactoryClass() throws ClassNotFoundException {
+        return Class.forName(getParameters().getProperty("connectionFactory"));
+    }
+
     protected String getConnectionFactoryUrl() {
         return getParameters().getProperty("connectionFactoryUrl");
     }
-    
+
     protected String getErrorUri() {
         return getParameters().getProperty("errorUri",getId() + ":queue:DLQ");
     }

Plugins/CorvusJMS/src/main/resources/org.jentrata.jms/conf/org/jentrata/spa/jms/conf/jms.module.internal.xml

@@ -23,6 +23,7 @@
 		<!-- connectionFactoryUrl is the ActiveMQ connection factory URL -->
 		<!-- example tcp://somehost:61616 -->
 		<!-- see http://activemq.apache.org/uri-protocols.html for more details -->
+		<parameter name="connectionFactory" value="${jentrata.activemq.connectionFactory:org.apache.activemq.ActiveMQConnectionFactory}" />
 		<parameter name="connectionFactoryUrl" value="${jentrata.activemq.connectionFactoryUrl:tcp://localhost:61616}" />
 		<parameter name="username" value="${jentrata.activemq.username:}" />
 		<parameter name="password" value="${jentrata.activemq.password:}" />

Plugins/CorvusJMS/src/test/resources/modules/jms-test-module.xml

@@ -2,7 +2,8 @@
 
 	<component id="jmsTest" name="test-jms">
 		<class>org.jentrata.spa.jms.module.JMSComponent</class>
-		<parameter name="connectionFactoryUrl" value="vm://localhost?broker.persistent=false" />		
+		<parameter name="connectionFactoryUrl" value="vm://localhost?broker.persistent=false" />
+		<parameter name="connectionFactory" value="org.apache.activemq.ActiveMQConnectionFactory" />
 	</component>
 
 </module>