Author: clebert.suconic(a)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);
Show replies by date