applied patch from AMQ-356

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@366156 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-01-05 10:55:13 +00:00
parent f73e2097dd
commit e310c21a8d
1 changed files with 7 additions and 1 deletions

View File

@ -261,7 +261,13 @@ public class ActiveMQManagedConnection implements ManagedConnection, ExceptionLi
* @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());
}
}
/**