1 files changed, 442 insertions, 0 deletions
diff --git a/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRAConnectionFactoryImpl.java b/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRAConnectionFactoryImpl.java
new file mode 100644
index 0000000000..77a38d5b34
--- /dev/null
+++ b/qpid/java/jca/src/main/java/org/apache/qpid/ra/QpidRAConnectionFactoryImpl.java
@@ -0,0 +1,442 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you 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.qpid.ra;
+
+import java.io.IOException;
+
+import javax.jms.Connection;
+import javax.jms.JMSException;
+import javax.jms.QueueConnection;
+import javax.jms.TopicConnection;
+import javax.jms.XAConnection;
+import javax.jms.XAQueueConnection;
+import javax.jms.XATopicConnection;
+import javax.naming.BinaryRefAddr;
+import javax.naming.Reference;
+import javax.resource.spi.ConnectionManager;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * The connection factory
+ *
+ */
+public class QpidRAConnectionFactoryImpl implements QpidRAConnectionFactory
+{
+   /** Serial version UID */
+   private static final long serialVersionUID = -5306006173783505760L;
+
+   /** The logger */
+   private static final Logger _log = LoggerFactory.getLogger(QpidRAConnectionFactoryImpl.class);
+
+   /** The managed connection factory */
+   private final QpidRAManagedConnectionFactory _mcf;
+
+   /** The connection manager */
+   private ConnectionManager _cm;
+
+   /** Naming reference */
+   private Reference _reference;
+
+   /**
+    * Constructor
+    * @param mcf The managed connection factory
+    * @param cm The connection manager
+    */
+   public QpidRAConnectionFactoryImpl(final QpidRAManagedConnectionFactory mcf, final ConnectionManager cm)
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("constructor(" + mcf + ", " + cm + ")");
+      }
+
+      this._mcf = mcf;
+
+      if (cm == null)
+      {
+         // This is standalone usage, no appserver
+         this._cm = new QpidRAConnectionManager();
+         if (_log.isTraceEnabled())
+         {
+            _log.trace("Created new ConnectionManager=" + this._cm);
+         }
+      }
+      else
+      {
+         this._cm = cm;
+      }
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Using ManagedConnectionFactory=" + mcf + ", ConnectionManager=" + this._cm);
+      }
+   }
+
+   /**
+    * Set the reference
+    * @param reference The reference
+    */
+   public void setReference(final Reference reference)
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("setReference(" + reference + ")");
+      }
+
+      this._reference = reference;
+   }
+
+   /**
+    * Get the reference
+    * @return The reference
+    */
+   public Reference getReference()
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("getReference()");
+      }
+      if (_reference == null)
+      {
+         try
+         {
+            _reference = new Reference(this.getClass().getCanonicalName(),
+                                      new BinaryRefAddr(ConnectionFactoryObjectFactory.QPID_CF,
+                                                        Util.serialize(this)),
+                                      ConnectionFactoryObjectFactory.class.getCanonicalName(),
+                                      null);
+         }
+         catch (final IOException ioe)
+         {
+            _log.error("Error while giving object Reference.", ioe);
+         }
+      }
+
+      return _reference;
+
+   }
+
+   /**
+    * Create a queue connection
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public QueueConnection createQueueConnection() throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createQueueConnection()");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf,
+                                                                      _cm,
+                                                                      QpidRAConnectionFactory.QUEUE_CONNECTION);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created queue connection: " + s);
+      }
+
+      return s;
+   }
+
+   /**
+    * Create a queue connection
+    * @param userName The user name
+    * @param password The password
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public QueueConnection createQueueConnection(final String userName, final String password) throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createQueueConnection(" + userName + ", ****)");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf,
+                                                                      _cm,
+                                                                      QpidRAConnectionFactory.QUEUE_CONNECTION);
+      s.setUserName(userName);
+      s.setPassword(password);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created queue connection: " + s);
+      }
+
+      return s;
+   }
+
+   /**
+    * Create a topic connection
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public TopicConnection createTopicConnection() throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createTopicConnection()");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf,
+                                                                      _cm,
+                                                                      QpidRAConnectionFactory.TOPIC_CONNECTION);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created topic connection: " + s);
+      }
+
+      return s;
+   }
+
+   /**
+    * Create a topic connection
+    * @param userName The user name
+    * @param password The password
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public TopicConnection createTopicConnection(final String userName, final String password) throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createTopicConnection(" + userName + ", ****)");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf,
+                                                                      _cm,
+                                                                      QpidRAConnectionFactory.TOPIC_CONNECTION);
+      s.setUserName(userName);
+      s.setPassword(password);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created topic connection: " + s);
+      }
+
+      return s;
+   }
+
+   /**
+    * Create a connection
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public Connection createConnection() throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createConnection()");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf, _cm, QpidRAConnectionFactory.CONNECTION);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created connection: " + s);
+      }
+
+      return s;
+   }
+
+   /**
+    * Create a connection
+    * @param userName The user name
+    * @param password The password
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public Connection createConnection(final String userName, final String password) throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createConnection(" + userName + ", ****)");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf, _cm, QpidRAConnectionFactory.CONNECTION);
+      s.setUserName(userName);
+      s.setPassword(password);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created connection: " + s);
+      }
+
+      return s;
+   }
+
+   /**
+    * Create a XA queue connection
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public XAQueueConnection createXAQueueConnection() throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createXAQueueConnection()");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf,
+                                                                      _cm,
+                                                                      QpidRAConnectionFactory.XA_QUEUE_CONNECTION);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created XA queue connection: " + s);
+      }
+
+      return s;
+   }
+
+   /**
+    * Create a XA  queue connection
+    * @param userName The user name
+    * @param password The password
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public XAQueueConnection createXAQueueConnection(final String userName, final String password) throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createXAQueueConnection(" + userName + ", ****)");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf,
+                                                                      _cm,
+                                                                      QpidRAConnectionFactory.XA_QUEUE_CONNECTION);
+      s.setUserName(userName);
+      s.setPassword(password);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created XA queue connection: " + s);
+      }
+
+      return s;
+   }
+
+   /**
+    * Create a XA topic connection
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public XATopicConnection createXATopicConnection() throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createXATopicConnection()");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf,
+                                                                      _cm,
+                                                                      QpidRAConnectionFactory.XA_TOPIC_CONNECTION);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created XA topic connection: " + s);
+      }
+
+      return s;
+   }
+
+   /**
+    * Create a XA topic connection
+    * @param userName The user name
+    * @param password The password
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public XATopicConnection createXATopicConnection(final String userName, final String password) throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createXATopicConnection(" + userName + ", ****)");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf,
+                                                                      _cm,
+                                                                      QpidRAConnectionFactory.XA_TOPIC_CONNECTION);
+      s.setUserName(userName);
+      s.setPassword(password);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created XA topic connection: " + s);
+      }
+
+      return s;
+   }
+
+   /**
+    * Create a XA connection
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public XAConnection createXAConnection() throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createXAConnection()");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf, _cm, QpidRAConnectionFactory.XA_CONNECTION);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created XA connection: " + s);
+      }
+
+      return s;
+   }
+
+   /**
+    * Create a XA connection
+    * @param userName The user name
+    * @param password The password
+    * @return The connection
+    * @exception JMSException Thrown if the operation fails
+    */
+   public XAConnection createXAConnection(final String userName, final String password) throws JMSException
+   {
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("createXAConnection(" + userName + ", ****)");
+      }
+
+      QpidRASessionFactoryImpl s = new QpidRASessionFactoryImpl(_mcf, _cm, QpidRAConnectionFactory.XA_CONNECTION);
+      s.setUserName(userName);
+      s.setPassword(password);
+
+      if (_log.isTraceEnabled())
+      {
+         _log.trace("Created XA connection: " + s);
+      }
+
+      return s;
+   }
+}