[hornetq-commits] JBoss hornetq SVN: r9349 - trunk/tests/src/org/hornetq/tests/integration/cluster/bridge.

[do-not-reply at jboss.org]

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();