[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