activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r366156 - /incubator/activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnection.java
Date Thu, 05 Jan 2006 10:55:15 GMT
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());
+        }
     }
 
     /**



Mime
View raw message