[hornetq-commits] JBoss hornetq SVN: r8177 - trunk/tests/src/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

Author: ataylor
Date: 2009-11-02 04:13:53 -0500 (Mon, 02 Nov 2009)
New Revision: 8177

Modified:
   trunk/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java
Log:
fixed test


Modified: trunk/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java	2009-11-02 09:05:17 UTC (rev 8176)
+++ trunk/tests/src/org/hornetq/tests/integration/client/LargeMessageTest.java	2009-11-02 09:13:53 UTC (rev 8177)
@@ -35,6 +35,7 @@
 import org.hornetq.core.server.HornetQServer;
 import org.hornetq.core.server.Queue;
 import org.hornetq.core.settings.impl.AddressSettings;
+import org.hornetq.core.settings.impl.AddressFullMessagePolicy;
 import org.hornetq.tests.integration.largemessage.LargeMessageTestBase;
 import org.hornetq.utils.DataConstants;
 import org.hornetq.utils.SimpleString;
@@ -1965,8 +1966,12 @@
 
       final int PAGE_SIZE = 10 * 1024;
 
-      server = createServer(realFiles, config, PAGE_SIZE, PAGE_MAX, new HashMap<String, AddressSettings>());
+      HashMap<String, AddressSettings> map = new HashMap<String, AddressSettings>();
 
+      AddressSettings value = new AddressSettings();
+      value.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);
+      map.put(ADDRESS.toString(), value);
+      server = createServer(realFiles, config, PAGE_SIZE, PAGE_MAX, map);
       server.start();
 
       final int numberOfBytes = 1024;
@@ -2026,7 +2031,7 @@
          {
             server.stop();
 
-            server = createServer(true, config, PAGE_SIZE, PAGE_MAX, new HashMap<String, AddressSettings>());
+            server = createServer(true, config, PAGE_SIZE, PAGE_MAX, map);
             server.start();
 
             sf = createInVMFactory();