[hornetq-commits] JBoss hornetq SVN: r8329 - branches/ClebertTemporary/tests/src/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-11-19 20:30:34 -0500 (Thu, 19 Nov 2009)
New Revision: 8329

Modified:
   branches/ClebertTemporary/tests/src/org/hornetq/tests/integration/client/DeadLetterAddressTest.java
Log:
Fixing tests

Modified: branches/ClebertTemporary/tests/src/org/hornetq/tests/integration/client/DeadLetterAddressTest.java
===================================================================
--- branches/ClebertTemporary/tests/src/org/hornetq/tests/integration/client/DeadLetterAddressTest.java	2009-11-20 01:23:23 UTC (rev 8328)
+++ branches/ClebertTemporary/tests/src/org/hornetq/tests/integration/client/DeadLetterAddressTest.java	2009-11-20 01:30:34 UTC (rev 8329)
@@ -179,6 +179,14 @@
          clientSession.rollback();
       }
 
+      long timeout = System.currentTimeMillis() + 5000;
+      
+      // DLA transfer is asynchronous fired on the rollback
+      while (System.currentTimeMillis() < timeout && ((Queue)server.getPostOffice().getBinding(qName).getBindable()).getMessageCount() != 0)
+      {
+         Thread.sleep(1);
+      }
+      
       assertEquals(0, ((Queue)server.getPostOffice().getBinding(qName).getBindable()).getMessageCount());
       ClientMessage m = clientConsumer.receiveImmediate();
       assertNull(m);