[hornetq-commits] JBoss hornetq SVN: r8174 - in trunk: tests/src/org/hornetq/tests/unit/core/paging/impl and 1 other directory.

do-not-reply at jboss.org do-not-reply at jboss.org
Sat Oct 31 04:05:49 EDT 2009


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,



More information about the hornetq-commits mailing list