[hornetq-commits] JBoss hornetq SVN: r8091 - in trunk/tests/src/org/hornetq/tests/integration: persistence and 1 other directory.
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();