Author: aidan
Date: Tue Jan 20 03:41:43 2009
New Revision: 735994
URL: http://svn.apache.org/viewvc?rev=735994&view=rev
Log:
Reorder receives, check that we don't get 3 messages first. Trying to debug
occasional failures on a slow cruise control machine.
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java?rev=735994&r1=735993&r2=735994&view=diff
==============================================================================
---
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
(original)
+++
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
Tue Jan 20 03:41:43 2009
@@ -95,19 +95,20 @@
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"));
-
-
- 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"));
-
- received = consumer.receive(1000);
- Assert.assertNull("More messages received", received);
+ 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);
+
+ 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"));
+
+ 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();
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
