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();
         
     }