Author: jmesnil
Date: 2010-04-27 04:12:07 -0400 (Tue, 27 Apr 2010)
New Revision: 9173
Modified:
trunk/tests/src/org/hornetq/tests/integration/client/DeadLetterAddressTest.java
Log:
fixed testReceiveWithListeners() test
* use receive(5000) instead of receiveImmediate() otherwise the consumer may look at the
DLQ too early
before the server has routed the message to the DLA after the redelivery attempts
Modified: trunk/tests/src/org/hornetq/tests/integration/client/DeadLetterAddressTest.java
===================================================================
---
trunk/tests/src/org/hornetq/tests/integration/client/DeadLetterAddressTest.java 2010-04-27
05:38:01 UTC (rev 9172)
+++
trunk/tests/src/org/hornetq/tests/integration/client/DeadLetterAddressTest.java 2010-04-27
08:12:07 UTC (rev 9173)
@@ -132,7 +132,7 @@
assertTrue(latch.await(5, TimeUnit.SECONDS));
assertEquals(handler.count, 2);
clientConsumer = clientSession.createConsumer(dlq);
- Message m = clientConsumer.receiveImmediate();
+ Message m = clientConsumer.receive(5000);
Assert.assertNotNull(m);
Assert.assertEquals(m.getBodyBuffer().readString(), "heyho!");
}
Show replies by date