activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1440012 - /activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java
Date Tue, 29 Jan 2013 17:31:30 GMT
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();
         
     }
 



Mime
View raw message