[jboss-cvs] JBoss Messaging SVN: r7756 - trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Mon Aug 17 11:50:05 EDT 2009


Author: jmesnil
Date: 2009-08-17 11:50:05 -0400 (Mon, 17 Aug 2009)
New Revision: 7756

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/FailoverNoSessionsFailoverTest.java
Log:
put session.close() in a finally block to clean up resources in case of failures...

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/FailoverNoSessionsFailoverTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/FailoverNoSessionsFailoverTest.java	2009-08-17 15:25:20 UTC (rev 7755)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/FailoverNoSessionsFailoverTest.java	2009-08-17 15:50:05 UTC (rev 7756)
@@ -154,24 +154,29 @@
                  
       session2.start();
       
-      for (int i = 0; i < numMessages; i++)
+      try
       {
+         for (int i = 0; i < numMessages; i++)
+         {
+            ClientMessage message2 = consumer2.receive(1000);
+
+            assertNotNull(message2);
+
+            assertEquals("aardvarks", message2.getBody().readString());
+
+            assertEquals(i, message2.getProperty(new SimpleString("count")));
+
+            message2.acknowledge();
+         }
+
          ClientMessage message2 = consumer2.receive(1000);
-         
-         assertNotNull(message2);
-         
-         assertEquals("aardvarks", message2.getBody().readString());
 
-         assertEquals(i, message2.getProperty(new SimpleString("count")));
-
-         message2.acknowledge();
+         assertNull(message2);
       }
-      
-      ClientMessage message2 = consumer2.receive(1000);
-      
-      assertNull(message2);
-      
-      session2.close();
+      finally
+      {
+         session2.close();
+      }
    }
    
    // Package protected ---------------------------------------------




More information about the jboss-cvs-commits mailing list