[hornetq-commits] JBoss hornetq SVN: r7925 - trunk/tests/src/org/hornetq/tests/integration/server.

[do-not-reply at jboss.org]

Author: ataylor
Date: 2009-08-27 11:56:13 -0400 (Thu, 27 Aug 2009)
New Revision: 7925

Modified:
   trunk/tests/src/org/hornetq/tests/integration/server/ExpiryRunnerTest.java
Log:
fixed test

Modified: trunk/tests/src/org/hornetq/tests/integration/server/ExpiryRunnerTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/server/ExpiryRunnerTest.java	2009-08-27 15:22:39 UTC (rev 7924)
+++ trunk/tests/src/org/hornetq/tests/integration/server/ExpiryRunnerTest.java	2009-08-27 15:56:13 UTC (rev 7925)
@@ -177,7 +177,7 @@
       consumer.close();
    }
 
-   public void testExpireWhilstConsuming() throws Exception
+   public void testExpireWhilstConsumingMessagesStillInOrder() throws Exception
    {
       ClientProducer producer = clientSession.createProducer(qName);
       ClientConsumer consumer = clientSession.createConsumer(qName);
@@ -216,9 +216,12 @@
 
       for(int i = 0; i < numMessages; i++)
       {
-         assertTrue(dummyMessageHandler.payloads.remove("m" + i));
+         if(dummyMessageHandler.payloads.isEmpty())
+         {
+            break;
+         }
+         assertTrue("m" + i, dummyMessageHandler.payloads.remove("m" + i));
       }
-      assertTrue(dummyMessageHandler.payloads.isEmpty());
       consumer.close();
       thr.join();
    }