diff options
author | Aidan Skinner <aidan@apache.org> | 2009-01-20 11:41:43 +0000 |
---|---|---|
committer | Aidan Skinner <aidan@apache.org> | 2009-01-20 11:41:43 +0000 |
commit | b4f77cd6a5ea505670a16d619717688e4f0ea43b (patch) | |
tree | 377f2d56a2e37fd12f8a80a384c51241a5edfbce | |
parent | bd1a4199a986f882e1aadc212be929b3d4484b1b (diff) | |
download | qpid-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.java | 23 |
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(); |