Author: arnaudsimon
Date: Thu Apr 3 02:41:42 2008
New Revision: 644245
URL: http://svn.apache.org/viewvc?rev=644245&view=rev
Log:
QPID-897 this test was intermittently failing because of too short timeouts.
This fix is a temporary measure until we agree about using a configurable
receive timeout.
Modified:
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java?rev=644245&r1=644244&r2=644245&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java
Thu Apr 3 02:41:42 2008
@@ -134,12 +134,12 @@
Message msg;
msg = consumer1.receive();
assertEquals("A", ((TextMessage) msg).getText());
- msg = consumer1.receive(100);
+ msg = consumer1.receive(1000);
assertEquals(null, msg);
msg = consumer2.receive();
assertEquals("A", ((TextMessage) msg).getText());
- msg = consumer2.receive(100);
+ msg = consumer2.receive(1000);
assertEquals(null, msg);
consumer2.close();
@@ -150,17 +150,17 @@
producer.send(session1.createTextMessage("B"));
_logger.info("Receive message on consumer 1 :expecting B");
- msg = consumer1.receive(100);
+ msg = consumer1.receive(1000);
assertEquals("B", ((TextMessage) msg).getText());
_logger.info("Receive message on consumer 1 :expecting null");
- msg = consumer1.receive(100);
+ msg = consumer1.receive(1000);
assertEquals(null, msg);
_logger.info("Receive message on consumer 3 :expecting B");
- msg = consumer3.receive(100);
+ msg = consumer3.receive(1000);
assertEquals("B", ((TextMessage) msg).getText());
_logger.info("Receive message on consumer 3 :expecting null");
- msg = consumer3.receive(100);
+ msg = consumer3.receive(1000);
assertEquals(null, msg);
// we need to unsubscribe as the session is NO_ACKNOWLEDGE
// messages for the durable subscriber are not deleted so the test
cannot
