Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

allow any implementation of PersistenceAdapterFactory to be used 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391091 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-04-03 17:39:32 +00:00
parent 39ad4a84cb
commit 609681a0cb
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
View File

@ -55,6 +55,7 @@ import org.apache.activemq.proxy.ProxyConnector;
import org.apache.activemq.security.MessageAuthorizationPolicy; import org.apache.activemq.security.MessageAuthorizationPolicy;
import org.apache.activemq.store.DefaultPersistenceAdapterFactory; import org.apache.activemq.store.DefaultPersistenceAdapterFactory;
import org.apache.activemq.store.PersistenceAdapter; import org.apache.activemq.store.PersistenceAdapter;
import org.apache.activemq.store.PersistenceAdapterFactory;
import org.apache.activemq.store.memory.MemoryPersistenceAdapter; import org.apache.activemq.store.memory.MemoryPersistenceAdapter;
import org.apache.activemq.thread.TaskRunnerFactory; import org.apache.activemq.thread.TaskRunnerFactory;
import org.apache.activemq.transport.TransportFactory; import org.apache.activemq.transport.TransportFactory;
@ -96,7 +97,7 @@ public class BrokerService implements Service {
private TaskRunnerFactory taskRunnerFactory; private TaskRunnerFactory taskRunnerFactory;
private UsageManager memoryManager; private UsageManager memoryManager;
private PersistenceAdapter persistenceAdapter; private PersistenceAdapter persistenceAdapter;
private DefaultPersistenceAdapterFactory persistenceFactory; private PersistenceAdapterFactory persistenceFactory;
private MessageAuthorizationPolicy messageAuthorizationPolicy; private MessageAuthorizationPolicy messageAuthorizationPolicy;
private List transportConnectors = new CopyOnWriteArrayList(); private List transportConnectors = new CopyOnWriteArrayList();
private List networkConnectors = new CopyOnWriteArrayList(); private List networkConnectors = new CopyOnWriteArrayList();
@ -460,7 +461,7 @@ public class BrokerService implements Service {
this.brokerName = brokerName; this.brokerName = brokerName;
} }
public DefaultPersistenceAdapterFactory getPersistenceFactory() { public PersistenceAdapterFactory getPersistenceFactory() {
if (persistenceFactory == null) { if (persistenceFactory == null) {
persistenceFactory = createPersistenceFactory(); persistenceFactory = createPersistenceFactory();
} }
@ -486,7 +487,7 @@ public class BrokerService implements Service {
this.dataDirectory = dataDirectory; this.dataDirectory = dataDirectory;
} }
public void setPersistenceFactory(DefaultPersistenceAdapterFactory persistenceFactory) { public void setPersistenceFactory(PersistenceAdapterFactory persistenceFactory) {
this.persistenceFactory = persistenceFactory; this.persistenceFactory = persistenceFactory;
} }