You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2013/01/29 18:31:30 UTC
svn commit: r1440012 -
/activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java
Author: tabish
Date: Tue Jan 29 17:31:30 2013
New Revision: 1440012
URL: http://svn.apache.org/viewvc?rev=1440012&view=rev
Log:
Apply patch for: https://issues.apache.org/jira/browse/AMQ-4281
Modified:
activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java
Modified: activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java?rev=1440012&r1=1440011&r2=1440012&view=diff
==============================================================================
--- activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java (original)
+++ activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java Tue Jan 29 17:31:30 2013
@@ -189,15 +189,18 @@ public class ActiveMQConnectionFactoryTe
}
};
cf.setExceptionListener(exListener);
+ connection.close();
connection = (ActiveMQConnection)cf.createConnection();
assertNotNull(connection.getExceptionListener());
assertEquals(exListener, connection.getExceptionListener());
+ connection.close();
connection = (ActiveMQConnection)cf.createConnection();
assertEquals(exListener, connection.getExceptionListener());
assertEquals(exListener, cf.getExceptionListener());
+ connection.close();
}
@@ -213,14 +216,17 @@ public class ActiveMQConnectionFactoryTe
};
connection.setClientInternalExceptionListener(listener);
cf.setClientInternalExceptionListener(listener);
+ connection.close();
connection = (ActiveMQConnection)cf.createConnection();
assertNotNull(connection.getClientInternalExceptionListener());
assertEquals(listener, connection.getClientInternalExceptionListener());
+ connection.close();
connection = (ActiveMQConnection)cf.createConnection();
assertEquals(listener, connection.getClientInternalExceptionListener());
assertEquals(listener, cf.getClientInternalExceptionListener());
+ connection.close();
}