summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAidan Skinner <aidan@apache.org>2009-01-20 11:41:43 +0000
committerAidan Skinner <aidan@apache.org>2009-01-20 11:41:43 +0000
commitb4f77cd6a5ea505670a16d619717688e4f0ea43b (patch)
tree377f2d56a2e37fd12f8a80a384c51241a5edfbce
parentbd1a4199a986f882e1aadc212be929b3d4484b1b (diff)
downloadqpid-python-b4f77cd6a5ea505670a16d619717688e4f0ea43b.tar.gz
Reorder receives, check that we don't get 3 messages first. Trying to debug occasional failures on a slow cruise control machine.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@735994 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java23
1 files changed, 12 insertions, 11 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
index 8d0d9b50d6..02db795534 100644
--- a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
+++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
@@ -95,19 +95,20 @@ public class TimeToLiveTest extends QpidTestCase
clientConnection.start();
//Receive Message 0
- Message received = consumer.receive(1000);
- Assert.assertNotNull("First message not received", received);
- Assert.assertTrue("First message doesn't have first set.", received.getBooleanProperty("first"));
- Assert.assertEquals("First message has incorrect TTL.", 0L, received.getLongProperty("TTL"));
-
+ Message receivedFirst = consumer.receive(1000);
+ Message receivedSecond = consumer.receive(1000);
+ Message receivedThird = consumer.receive(1000);
+
+ // Only first and last messages sent should survive expiry
+ Assert.assertNull("More messages received", receivedThird);
- received = consumer.receive(1000);
- Assert.assertNotNull("Final message not received", received);
- Assert.assertFalse("Final message has first set.", received.getBooleanProperty("first"));
- Assert.assertEquals("Final message has incorrect TTL.", 0L, received.getLongProperty("TTL"));
+ Assert.assertNotNull("First message not received", receivedFirst);
+ Assert.assertTrue("First message doesn't have first set.", receivedFirst.getBooleanProperty("first"));
+ Assert.assertEquals("First message has incorrect TTL.", 0L, receivedFirst.getLongProperty("TTL"));
- received = consumer.receive(1000);
- Assert.assertNull("More messages received", received);
+ Assert.assertNotNull("Final message not received", receivedSecond);
+ Assert.assertFalse("Final message has first set.", receivedSecond.getBooleanProperty("first"));
+ Assert.assertEquals("Final message has incorrect TTL.", 0L, receivedSecond.getLongProperty("TTL"));
clientConnection.close();