[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