1 files changed, 122 insertions, 0 deletions
diff --git a/branches/sca-java-1.x/modules/binding-ws-axis2-jms/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/jms/JMSConnectionFactoryManager.java b/branches/sca-java-1.x/modules/binding-ws-axis2-jms/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/jms/JMSConnectionFactoryManager.java
new file mode 100644
index 0000000000..fb16500efc
--- /dev/null
+++ b/branches/sca-java-1.x/modules/binding-ws-axis2-jms/src/main/java/org/apache/tuscany/sca/binding/ws/axis2/jms/JMSConnectionFactoryManager.java
@@ -0,0 +1,122 @@
+/*
+* Copyright 2004,2005 The Apache Software Foundation.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*      http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+package org.apache.tuscany.sca.binding.ws.axis2.jms;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.naming.Context;
+
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.description.Parameter;
+import org.apache.axis2.description.ParameterInclude;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+/**
+ * Class managing a set of {@link JMSConnectionFactory} objects.
+ */
+public class JMSConnectionFactoryManager {
+
+    private static final Log log = LogFactory.getLog(JMSConnectionFactoryManager.class);
+
+    /** A Map containing the JMS connection factories managed by this, keyed by name */
+    private final Map<String,JMSConnectionFactory> connectionFactories =
+        new HashMap<String,JMSConnectionFactory>();
+
+    /**
+     * Construct a Connection factory manager for the JMS transport sender or receiver
+     * @param trpInDesc
+     */
+    public JMSConnectionFactoryManager(ParameterInclude trpInDesc) {
+        loadConnectionFactoryDefinitions(trpInDesc);
+    }
+
+    /**
+     * Create JMSConnectionFactory instances for the definitions in the transport configuration,
+     * and add these into our collection of connectionFactories map keyed by name
+     *
+     * @param trpDesc the transport description for JMS
+     */
+    private void loadConnectionFactoryDefinitions(ParameterInclude trpDesc) {
+
+        for (Object o : trpDesc.getParameters()) {
+            Parameter p = (Parameter)o;
+            try {
+                JMSConnectionFactory jmsConFactory = new JMSConnectionFactory(p);
+                connectionFactories.put(jmsConFactory.getName(), jmsConFactory);
+            } catch (AxisJMSException e) {
+                log.error("Error setting up connection factory : " + p.getName(), e);
+            }
+        }
+    }
+
+    /**
+     * Get the JMS connection factory with the given name.
+     *
+     * @param name the name of the JMS connection factory
+     * @return the JMS connection factory or null if no connection factory with
+     *         the given name exists
+     */
+    public JMSConnectionFactory getJMSConnectionFactory(String name) {
+        return connectionFactories.get(name);
+    }
+
+    /**
+     * Get the JMS connection factory that matches the given properties, i.e. referring to
+     * the same underlying connection factory. Used by the JMSSender to determine if already
+     * available resources should be used for outgoing messages
+     *
+     * @param props a Map of connection factory JNDI properties and name
+     * @return the JMS connection factory or null if no connection factory compatible
+     *         with the given properties exists
+     */
+    public JMSConnectionFactory getJMSConnectionFactory(Map<String,String> props) {
+        for (JMSConnectionFactory cf : connectionFactories.values()) {
+            Map<String,String> cfProperties = cf.getParameters();
+
+            if (equals(props.get(JMSConstants.PARAM_CONFAC_JNDI_NAME),
+                cfProperties.get(JMSConstants.PARAM_CONFAC_JNDI_NAME))
+                &&
+                equals(props.get(Context.INITIAL_CONTEXT_FACTORY),
+                    cfProperties.get(Context.INITIAL_CONTEXT_FACTORY))
+                &&
+                equals(props.get(Context.PROVIDER_URL),
+                    cfProperties.get(Context.PROVIDER_URL))
+                &&
+                equals(props.get(Context.SECURITY_PRINCIPAL),
+                    cfProperties.get(Context.SECURITY_PRINCIPAL))
+                &&
+                equals(props.get(Context.SECURITY_CREDENTIALS),
+                    cfProperties.get(Context.SECURITY_CREDENTIALS))) {
+                return cf;
+            }
+        }
+        return null;
+    }
+
+    /**
+     * Compare two values preventing NPEs
+     */
+    private static boolean equals(Object s1, Object s2) {
+        return s1 == s2 || s1 != null && s1.equals(s2);
+    }
+
+    protected void handleException(String msg, Exception e) throws AxisFault {
+        log.error(msg, e);
+        throw new AxisFault(msg, e);
+    }
+}