[jboss-cvs] JBoss Messaging SVN: r6644 - trunk/tests/src/org/jboss/messaging/tests/integration/client.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-05-01 11:53:10 -0400 (Fri, 01 May 2009)
New Revision: 6644

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/client/LargeMessageTest.java
Log:
just a small tweak to fix the test

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/LargeMessageTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/LargeMessageTest.java	2009-05-01 10:44:24 UTC (rev 6643)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/LargeMessageTest.java	2009-05-01 15:53:10 UTC (rev 6644)
@@ -1017,7 +1017,7 @@
          }
       }
    }
-
+   
    public void testSendStreamingSingleMessage() throws Exception
    {
       ClientSession session = null;
@@ -1069,6 +1069,13 @@
          // }
 
          session.commit();
+         
+         // addGlobalSize on LargeMessage is only done after the delivery, and the addSize could be asynchronous
+         long timeout = System.currentTimeMillis() + 5000;
+         while (timeout > System.currentTimeMillis() && server.getPostOffice().getPagingManager().getGlobalSize() != 0)
+         {
+            Thread.sleep(100);
+         }
 
          assertEquals(0l, server.getPostOffice().getPagingManager().getGlobalSize());
          assertEquals(0, ((Queue)server.getPostOffice().getBinding(ADDRESS).getBindable()).getDeliveringCount());