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

do-not-reply at jboss.org do-not-reply at jboss.org
Tue May 17 22:38:49 EDT 2011


Author: clebert.suconic at jboss.com
Date: 2011-05-17 22:38:49 -0400 (Tue, 17 May 2011)
New Revision: 10695

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingTest.java
Log:
tweaks on test

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingTest.java	2011-05-18 02:31:12 UTC (rev 10694)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingTest.java	2011-05-18 02:38:49 UTC (rev 10695)
@@ -3574,7 +3574,7 @@
 
          ClientMessage message = null;
 
-         for (int i = 0; i < 500; i++)
+         for (int i = 0; i < 100; i++)
          {
             log.info("send message #" + i);
             message = session.createMessage(true);
@@ -3588,10 +3588,6 @@
             if ((i + 1) % 2 == 0)
             {
                session.commit();
-               if (i < 400)
-               {
-                  pgStoreAddress.forceAnotherPage();
-               }
             }
          }
 
@@ -3626,7 +3622,7 @@
             pgStoreDLA.startPaging();
          }
 
-         for (int i = 2; i < 500; i++)
+         for (int i = 2; i < 100; i++)
          {
             log.info("Received message " + i);
             message = cons.receive(5000);
@@ -3666,7 +3662,7 @@
          
          cons = session.createConsumer(ADDRESS);
 
-         for (int i = 2; i < 500; i++)
+         for (int i = 2; i < 100; i++)
          {
             log.info("Received message " + i);
             message = cons.receive(5000);



More information about the hornetq-commits mailing list