From 618678458931fed8e6c083635b2d453685e36c5c Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Tue, 9 Oct 2007 13:19:37 +0000 Subject: Qpid-627 Patch provided by Aidan Skinner to address hangs in DurableSubscriptionTest. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583154 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/test/unit/topic/DurableSubscriptionTest.java | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) (limited to 'java') diff --git a/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java b/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java index a9c93d7227..a0a8eb10ed 100644 --- a/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java +++ b/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java @@ -143,17 +143,17 @@ public class DurableSubscriptionTest extends TestCase producer.send(session1.createTextMessage("A")); Message msg; - msg = consumer1.receive(100); + msg = consumer1.receive(500); assertNotNull("Message should be available", msg); assertEquals("Message Text doesn't match", "A", ((TextMessage) msg).getText()); - msg = consumer1.receive(100); + msg = consumer1.receive(500); assertNull("There should be no more messages for consumption on consumer1.", msg); msg = consumer2.receive(); assertNotNull(msg); assertEquals("Consumer 2 should also received the first msg.", "A", ((TextMessage) msg).getText()); - msg = consumer2.receive(100); + msg = consumer2.receive(500); assertNull("There should be no more messages for consumption on consumer2.", msg); consumer2.close(); @@ -164,21 +164,24 @@ public class DurableSubscriptionTest extends TestCase producer.send(session1.createTextMessage("B")); _logger.info("Receive message on consumer 1 :expecting B"); - msg = consumer1.receive(100); + msg = consumer1.receive(500); assertNotNull("Consumer 1 should get message 'B'.", msg); assertEquals("Incorrect Message recevied on consumer1.", "B", ((TextMessage) msg).getText()); _logger.info("Receive message on consumer 1 :expecting null"); - msg = consumer1.receive(100); + msg = consumer1.receive(500); assertNull("There should be no more messages for consumption on consumer1.", msg); _logger.info("Receive message on consumer 3 :expecting B"); - msg = consumer3.receive(100); + msg = consumer3.receive(500); assertNotNull("Consumer 3 should get message 'B'.", msg); assertEquals("Incorrect Message recevied on consumer4.", "B", ((TextMessage) msg).getText()); _logger.info("Receive message on consumer 3 :expecting null"); - msg = consumer3.receive(100); + msg = consumer3.receive(500); assertNull("There should be no more messages for consumption on consumer3.", msg); - + + consumer1.close(); + consumer3.close(); + con.close(); } -- cgit v1.2.1