You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ai...@apache.org on 2009/01/20 12:41:44 UTC
svn commit: r735994 -
/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
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:commits-subscribe@qpid.apache.org