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

[jboss-cvs-commits at lists.jboss.org]

Author: jmesnil
Date: 2009-08-17 12:09:50 -0400 (Mon, 17 Aug 2009)
New Revision: 7758

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

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/FailureListenerOnFailoverTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/FailureListenerOnFailoverTest.java	2009-08-17 15:59:53 UTC (rev 7757)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/FailureListenerOnFailoverTest.java	2009-08-17 16:09:50 UTC (rev 7758)
@@ -207,17 +207,22 @@
          assertEquals(0, listener.getFailCount());
       }
 
-      // Do some stuff to make sure sessions failed over/reconnected ok
-      int i = 0;
-      for (ClientSession session : sessions)
+      try
       {
-         session.createQueue("testaddress" + i, "testaddress" + i, false);
-         session.deleteQueue("testaddress" + i);
-         i++;
-         session.close();
+         // Do some stuff to make sure sessions failed over/reconnected ok
+         int i = 0;
+         for (ClientSession session : sessions)
+         {
+            session.createQueue("testaddress" + i, "testaddress" + i, false);
+            session.deleteQueue("testaddress" + i);
+            i++;
+            session.close();
+         }
       }
-
-      sf.close();
+      finally
+      {
+         sf.close();
+      }
    }
 
    /*