Author: jmesnil
Date: 2010-06-22 09:29:47 -0400 (Tue, 22 Jun 2010)
New Revision: 9349
Modified:
trunk/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeWithPagingTest.java
Log:
https://jira.jboss.org/browse/HORNETQ-382
* reduce test value to make the issue appear faster (at message 306 on my laptop)
* add missing message ack
Modified:
trunk/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeWithPagingTest.java
===================================================================
---
trunk/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeWithPagingTest.java 2010-06-21
16:13:48 UTC (rev 9348)
+++
trunk/tests/src/org/hornetq/tests/integration/cluster/bridge/BridgeWithPagingTest.java 2010-06-22
13:29:47 UTC (rev 9349)
@@ -139,8 +139,8 @@
AddressSettings addressSettings = new AddressSettings();
addressSettings.setRedeliveryDelay(0);
- addressSettings.setMaxSizeBytes(10485760);
- addressSettings.setPageSizeBytes(1048576);
+ addressSettings.setMaxSizeBytes(1048576);
+ addressSettings.setPageSizeBytes(104857);
addressSettings.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);
server0.getConfiguration().getAddressesSettings().put("#",
addressSettings);
@@ -185,7 +185,7 @@
};
t.start();
- final int numMessages = 5000;
+ final int numMessages = 500;
SimpleString propKey = new SimpleString("propkey");
@@ -206,8 +206,9 @@
{
System.out.println("<<< " + i);
ClientMessage r1 = cons1.receive(1500);
- Assert.assertNotNull(r1);
+ Assert.assertNotNull("did not receive message n�" + i, r1);
Assert.assertEquals(i, r1.getObjectProperty(propKey));
+ r1.acknowledge();
}
session0.close();