[hornetq-commits] JBoss hornetq SVN: r8174 - in trunk: tests/src/org/hornetq/tests/unit/core/paging/impl and 1 other directory.
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,