[hornetq-commits] JBoss hornetq SVN: r9173 - trunk/tests/src/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

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!");
    }