From 609681a0cbbe5658ce67409112414e8f0c7f1b8b Mon Sep 17 00:00:00 2001 From: James Strachan Date: Mon, 3 Apr 2006 17:39:32 +0000 Subject: [PATCH] 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 --- .../java/org/apache/activemq/broker/BrokerService.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java index 9852aa7514..746e2e1ceb 100644 --- a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java @@ -55,6 +55,7 @@ import org.apache.activemq.proxy.ProxyConnector; 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 @@ public class BrokerService implements Service { 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 @@ public class BrokerService implements Service { this.brokerName = brokerName; } - public DefaultPersistenceAdapterFactory getPersistenceFactory() { + public PersistenceAdapterFactory getPersistenceFactory() { if (persistenceFactory == null) { persistenceFactory = createPersistenceFactory(); } @@ -486,7 +487,7 @@ public class BrokerService implements Service { this.dataDirectory = dataDirectory; } - public void setPersistenceFactory(DefaultPersistenceAdapterFactory persistenceFactory) { + public void setPersistenceFactory(PersistenceAdapterFactory persistenceFactory) { this.persistenceFactory = persistenceFactory; }