From e7fa56f28113fc28c4118a76ada5c58d4aa6155a Mon Sep 17 00:00:00 2001
From: Martin Ritchie <ritchiem@apache.org>
Date: Tue, 18 Mar 2008 15:20:15 +0000
Subject: QPID-854 : Renabled the test as the cause was the lack of closing of
 the purgeQueue connection in VMTestCase

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@638412 13f79535-47bb-0310-9956-ffa450edef68
---
 .../main/java/org/apache/qpid/test/VMTestCase.java |  2 ++
 .../qpid/test/client/QueueBrowserAutoAckTest.java  | 22 +++++++++++-----------
 2 files changed, 13 insertions(+), 11 deletions(-)

(limited to 'java')

diff --git a/java/systests/src/main/java/org/apache/qpid/test/VMTestCase.java b/java/systests/src/main/java/org/apache/qpid/test/VMTestCase.java
index b6646ba0e4..a58b7a116a 100644
--- a/java/systests/src/main/java/org/apache/qpid/test/VMTestCase.java
+++ b/java/systests/src/main/java/org/apache/qpid/test/VMTestCase.java
@@ -143,6 +143,8 @@ public class VMTestCase extends TestCase
             }
 
         }
+        
+        connection.close();
     }
 
     public int getMessageCount(String queueName)
diff --git a/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java b/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
index ac6f8da457..fccc80ec75 100644
--- a/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
+++ b/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
@@ -462,17 +462,17 @@ public class QueueBrowserAutoAckTest extends FailoverBaseCase
 
         // The IoServiceListenerSupport seems to get stuck in with a managedSession that isn't closing when requested.
         // So it hangs waiting for the session.
-//        int messages = 50;
-//
-//        sendMessages("connection1", messages);
-//        sendMessages("connection2", messages);
-//
-//        failBroker();
-//
-//        checkQueueDepth(messages);
-//
-//        //Validate all messages still on Broker 1
-//        validate(messages);
+        int messages = 50;
+
+        sendMessages("connection1", messages);
+        sendMessages("connection2", messages);
+
+        failBroker();
+
+        checkQueueDepth(messages);
+
+        //Validate all messages still on Broker 1
+        validate(messages);
     }
 
     public void loop() throws JMSException
-- 
cgit v1.2.1