You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@activemq.apache.org by js...@apache.org on 2006/01/05 11:55:15 UTC

svn commit: r366156 - /incubator/activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnection.java

Author: jstrachan
Date: Thu Jan  5 02:55:13 2006
New Revision: 366156

URL: http://svn.apache.org/viewcvs?rev=366156&view=rev
Log:
applied patch from AMQ-356

Modified:
    incubator/activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnection.java

Modified: incubator/activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnection.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnection.java?rev=366156&r1=366155&r2=366156&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnection.java (original)
+++ incubator/activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnection.java Thu Jan  5 02:55:13 2006
@@ -261,7 +261,13 @@
      * @see javax.resource.spi.ManagedConnection#associateConnection(java.lang.Object)
      */
     public void associateConnection(Object connection) throws ResourceException {
-        throw new ResourceException("Not supported.");
+        if (connection instanceof ManagedConnectionProxy) {
+            ManagedConnectionProxy proxy = (ManagedConnectionProxy) connection;
+            proxyConnections.add(proxy);
+        }
+        else {
+            throw new ResourceException("Not supported : associating connection instance of " + connection.getClass().getName());
+        }
     }
 
     /**