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;
}