[hornetq-commits] JBoss hornetq SVN: r8091 - in trunk/tests/src/org/hornetq/tests/integration: persistence and 1 other directory.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2009-10-13 09:01:11 -0400 (Tue, 13 Oct 2009)
New Revision: 8091

Modified:
   trunk/tests/src/org/hornetq/tests/integration/largemessage/LargeMessageCleanupTest.java
   trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteQueueRestartTest.java
Log:
ensure created sessions are properly closed

Modified: trunk/tests/src/org/hornetq/tests/integration/largemessage/LargeMessageCleanupTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/largemessage/LargeMessageCleanupTest.java	2009-10-13 12:53:06 UTC (rev 8090)
+++ trunk/tests/src/org/hornetq/tests/integration/largemessage/LargeMessageCleanupTest.java	2009-10-13 13:01:11 UTC (rev 8091)
@@ -160,6 +160,7 @@
 
          validateNoFilesOnLargeDir();
 
+         session.close();
       }
       finally
       {

Modified: trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteQueueRestartTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteQueueRestartTest.java	2009-10-13 12:53:06 UTC (rev 8090)
+++ trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteQueueRestartTest.java	2009-10-13 13:01:11 UTC (rev 8091)
@@ -14,6 +14,7 @@
 package org.hornetq.tests.integration.persistence;
 
 import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 
 import org.hornetq.core.client.ClientMessage;
 import org.hornetq.core.client.ClientProducer;
@@ -93,9 +94,9 @@
          {
             try
             {
-               count.countDown();
                session.deleteQueue(ADDRESS);
                session.close();
+               count.countDown();
             }
             catch (HornetQException e)
             {
@@ -103,7 +104,7 @@
          }
       }.start();
 
-      count.await();
+      assertTrue(count.await(5, TimeUnit.SECONDS));
 
       server.stop();