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();
}
Show replies by date