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

enable setting of the ReferenceStoreAdapter 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515060 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-03-06 10:36:53 +00:00
parent 985b4ce0df
commit 0b1a064092
2 changed files with 26 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
View File

@ -646,4 +646,12 @@ public class AMQPersistenceAdapter implements PersistenceAdapter,UsageListener{
public void setSyncOnWrite(boolean syncOnWrite){
this.syncOnWrite=syncOnWrite;
}
/**
* @param referenceStoreAdapter the referenceStoreAdapter to set
*/
public void setReferenceStoreAdapter(ReferenceStoreAdapter referenceStoreAdapter){
this.referenceStoreAdapter=referenceStoreAdapter;
}
}

18
activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java
View File

@ -17,6 +17,7 @@ package org.apache.activemq.store.amq;
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 @@ public class AMQPersistenceAdapterFactory implements PersistenceAdapterFactory{
private File dataDirectory;
private int journalThreadPriority = Thread.MAX_PRIORITY;
private String brokerName="localhost";
private ReferenceStoreAdapter referenceStoreAdapter;
/**
* @return a AMQPersistenceAdapter
@ -111,4 +113,20 @@ public class AMQPersistenceAdapterFactory implements PersistenceAdapterFactory{
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;
}
}