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