diff --git a/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java b/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
index 7fb5c14dac..b85c902d6a 100644
--- a/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
@@ -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;
+    }
 }
diff --git a/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java b/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java
index 00e9aba655..4a40ff960b 100644
--- a/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java
@@ -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;
+    }
 }