[jboss-cvs] JBoss Messaging SVN: r6681 - 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-05 21:17:52 -0400 (Tue, 05 May 2009)
New Revision: 6681

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerWindowSizeTest.java
Log:
tweaks

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerWindowSizeTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerWindowSizeTest.java	2009-05-06 01:05:37 UTC (rev 6680)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerWindowSizeTest.java	2009-05-06 01:17:52 UTC (rev 6681)
@@ -887,6 +887,10 @@
 
          ClientSessionFactory sf = createInVMFactory();
          sf.setConsumerWindowSize(-1);
+         if (largeMessages)
+         {
+            sf.setMinLargeMessageSize(100);
+         }
 
          sessionA = sf.createSession(false, true, true);
 
@@ -904,8 +908,10 @@
          ClientConsumerInternal consB = (ClientConsumerInternal)sessionB.createConsumer(ADDRESS);
 
          {
-            // We can only guarantee round robing with WindowSize = -1, after the ServerConsumer object received SessionConsumerFlowCreditMessage(-1)
-            // Since that is done asynchronously we verify that the information was received before we proceed on sending messages or else the distribution won't be 
+            // We can only guarantee round robing with WindowSize = -1, after the ServerConsumer object received
+            // SessionConsumerFlowCreditMessage(-1)
+            // Since that is done asynchronously we verify that the information was received before we proceed on
+            // sending messages or else the distribution won't be
             // even as expected by the test
             Bindings bindings = server.getPostOffice().getBindingsForAddress(ADDRESS);
 
@@ -921,7 +927,6 @@
                   long timeout = System.currentTimeMillis() + 5000;
                   while (timeout > System.currentTimeMillis() && consumerImpl.getAvailableCredits() != null)
                   {
-                     new Exception("Trace").printStackTrace();
                      Thread.sleep(10);
                   }
                }