Author: timfox Date: 2009-10-31 04:05:49 -0400 (Sat, 31 Oct 2009) New Revision: 8174 Modified: trunk/src/main/org/hornetq/core/settings/impl/AddressSettings.java trunk/tests/src/org/hornetq/tests/unit/core/paging/impl/PagingManagerImplTest.java Log: Make BLOCK default policy Modified: trunk/src/main/org/hornetq/core/settings/impl/AddressSettings.java =================================================================== --- trunk/src/main/org/hornetq/core/settings/impl/AddressSettings.java 2009-10-30 20:27:00 UTC (rev 8173) +++ trunk/src/main/org/hornetq/core/settings/impl/AddressSettings.java 2009-10-31 08:05:49 UTC (rev 8174) @@ -36,7 +36,7 @@ public static final int DEFAULT_MAX_SIZE_BYTES = -1; - public static final AddressFullMessagePolicy DEFAULT_ADDRESS_FULL_MESSAGE_POLICY = AddressFullMessagePolicy.PAGE; + public static final AddressFullMessagePolicy DEFAULT_ADDRESS_FULL_MESSAGE_POLICY = AddressFullMessagePolicy.BLOCK; public static final int DEFAULT_PAGE_SIZE = 10 * 1024 * 1024; Modified: trunk/tests/src/org/hornetq/tests/unit/core/paging/impl/PagingManagerImplTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/unit/core/paging/impl/PagingManagerImplTest.java 2009-10-30 20:27:00 UTC (rev 8173) +++ trunk/tests/src/org/hornetq/tests/unit/core/paging/impl/PagingManagerImplTest.java 2009-10-31 08:05:49 UTC (rev 8174) @@ -29,6 +29,7 @@ import org.hornetq.core.server.ServerMessage; import org.hornetq.core.server.impl.ServerMessageImpl; import org.hornetq.core.settings.HierarchicalRepository; +import org.hornetq.core.settings.impl.AddressFullMessagePolicy; import org.hornetq.core.settings.impl.AddressSettings; import org.hornetq.core.settings.impl.HierarchicalObjectRepository; import org.hornetq.tests.util.RandomUtil; @@ -58,8 +59,11 @@ { HierarchicalRepository<AddressSettings> addressSettings = new HierarchicalObjectRepository<AddressSettings>(); - addressSettings.setDefault(new AddressSettings()); + AddressSettings settings = new AddressSettings(); + settings.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE); + addressSettings.setDefault(settings); + PagingManagerImpl managerImpl = new PagingManagerImpl(new PagingStoreFactoryNIO(getPageDir(), new OrderedExecutorFactory(Executors.newCachedThreadPool())), new NullStorageManager(), addressSettings,