You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/04/03 19:39:32 UTC

svn commit: r391091 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java

Author: jstrachan
Date: Mon Apr  3 10:39:32 2006
New Revision: 391091

URL: http://svn.apache.org/viewcvs?rev=391091&view=rev
Log:
allow any implementation of PersistenceAdapterFactory to be used

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java?rev=391091&r1=391090&r2=391091&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java Mon Apr  3 10:39:32 2006
@@ -55,6 +55,7 @@
 import org.apache.activemq.security.MessageAuthorizationPolicy;
 import org.apache.activemq.store.DefaultPersistenceAdapterFactory;
 import org.apache.activemq.store.PersistenceAdapter;
+import org.apache.activemq.store.PersistenceAdapterFactory;
 import org.apache.activemq.store.memory.MemoryPersistenceAdapter;
 import org.apache.activemq.thread.TaskRunnerFactory;
 import org.apache.activemq.transport.TransportFactory;
@@ -96,7 +97,7 @@
     private TaskRunnerFactory taskRunnerFactory;
     private UsageManager memoryManager;
     private PersistenceAdapter persistenceAdapter;
-    private DefaultPersistenceAdapterFactory persistenceFactory;
+    private PersistenceAdapterFactory persistenceFactory;
     private MessageAuthorizationPolicy messageAuthorizationPolicy;
     private List transportConnectors = new CopyOnWriteArrayList();
     private List networkConnectors = new CopyOnWriteArrayList();
@@ -460,7 +461,7 @@
         this.brokerName = brokerName;
     }
 
-    public DefaultPersistenceAdapterFactory getPersistenceFactory() {
+    public PersistenceAdapterFactory getPersistenceFactory() {
         if (persistenceFactory == null) {
             persistenceFactory = createPersistenceFactory();
         }
@@ -486,7 +487,7 @@
         this.dataDirectory = dataDirectory;
     }
 
-    public void setPersistenceFactory(DefaultPersistenceAdapterFactory persistenceFactory) {
+    public void setPersistenceFactory(PersistenceAdapterFactory persistenceFactory) {
         this.persistenceFactory = persistenceFactory;
     }