[hornetq-commits] JBoss hornetq SVN: r8088 - trunk/tests/src/org/hornetq/tests/integration/server.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2009-10-13 08:44:22 -0400 (Tue, 13 Oct 2009)
New Revision: 8088

Modified:
   trunk/tests/src/org/hornetq/tests/integration/server/LVQRecoveryTest.java
Log:
ensure created sessions are properly closed

Modified: trunk/tests/src/org/hornetq/tests/integration/server/LVQRecoveryTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/server/LVQRecoveryTest.java	2009-10-13 12:39:36 UTC (rev 8087)
+++ trunk/tests/src/org/hornetq/tests/integration/server/LVQRecoveryTest.java	2009-10-13 12:44:22 UTC (rev 8088)
@@ -71,7 +71,11 @@
       producer.send(m4);
       clientSessionXa.end(xid, XAResource.TMSUCCESS);
       clientSessionXa.prepare(xid);
+
+      clientSession.close();
+      clientSessionXa.close();
       restartServer();
+      
       clientSessionXa.commit(xid, true);
       ClientConsumer consumer = clientSession.createConsumer(qName1);
       clientSession.start();
@@ -139,7 +143,10 @@
       clientSessionXa.end(xid, XAResource.TMSUCCESS);
       clientSessionXa.prepare(xid);
 
+      clientSession.close();
+      clientSessionXa.close();
       restartServer();
+      
       clientSessionXa.rollback(xid);
       consumer = clientSession.createConsumer(qName1);
       clientSession.start();