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

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();