Author: rajdavies
Date: Tue Mar 6 02:36:53 2007
New Revision: 515060
URL: http://svn.apache.org/viewvc?view=rev&rev=515060
Log:
enable setting of the ReferenceStoreAdapter
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java?view=diff&rev=515060&r1=515059&r2=515060
==============================================================================
---
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
(original)
+++
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
Tue Mar 6 02:36:53 2007
@@ -646,4 +646,12 @@
public void setSyncOnWrite(boolean syncOnWrite){
this.syncOnWrite=syncOnWrite;
}
+
+
+ /**
+ * @param referenceStoreAdapter the referenceStoreAdapter to set
+ */
+ public void setReferenceStoreAdapter(ReferenceStoreAdapter
referenceStoreAdapter){
+ this.referenceStoreAdapter=referenceStoreAdapter;
+ }
}
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java?view=diff&rev=515060&r1=515059&r2=515060
==============================================================================
---
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java
(original)
+++
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java
Tue Mar 6 02:36:53 2007
@@ -17,6 +17,7 @@
import java.io.File;
import org.apache.activemq.store.PersistenceAdapter;
import org.apache.activemq.store.PersistenceAdapterFactory;
+import org.apache.activemq.store.ReferenceStoreAdapter;
import org.apache.activemq.thread.TaskRunnerFactory;
import org.apache.activemq.util.IOHelper;
@@ -33,6 +34,7 @@
private File dataDirectory;
private int journalThreadPriority = Thread.MAX_PRIORITY;
private String brokerName="localhost";
+ private ReferenceStoreAdapter referenceStoreAdapter;
/**
* @return a AMQPersistenceAdapter
@@ -110,5 +112,21 @@
*/
public void setBrokerName(String brokerName){
this.brokerName=brokerName;
+ }
+
+
+ /**
+ * @return the referenceStoreAdapter
+ */
+ public ReferenceStoreAdapter getReferenceStoreAdapter(){
+ return this.referenceStoreAdapter;
+ }
+
+
+ /**
+ * @param referenceStoreAdapter the referenceStoreAdapter to set
+ */
+ public void setReferenceStoreAdapter(ReferenceStoreAdapter
referenceStoreAdapter){
+ this.referenceStoreAdapter=referenceStoreAdapter;
}
}