svn commit: r557386 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ReferenceStoreAdapter.java

[rajdavies]

Author: rajdavies
Date: Wed Jul 18 13:31:09 2007
New Revision: 557386

URL: http://svn.apache.org/viewvc?view=rev&rev=557386
Log:
Added some java doc

Modified:
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ReferenceStoreAdapter.java

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ReferenceStoreAdapter.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ReferenceStoreAdapter.java?view=diff&rev=557386&r1=557385&r2=557386
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ReferenceStoreAdapter.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ReferenceStoreAdapter.java
 Wed Jul 18 13:31:09 2007
@@ -18,10 +18,13 @@
 package org.apache.activemq.store;
 
 import java.io.IOException;
+import java.util.Map;
 import java.util.Set;
 
 import org.apache.activemq.command.ActiveMQQueue;
 import org.apache.activemq.command.ActiveMQTopic;
+import org.apache.activemq.command.TransactionId;
+import org.apache.activemq.store.amq.AMQTx;
 
 /**
  * Adapter to the actual persistence mechanism used with ActiveMQ
@@ -32,14 +35,24 @@
 
     /**
      * Factory method to create a new queue message store with the given 
destination name
+     * @param destination 
+     * @return the QueueReferenceStore
+     * @throws IOException 
      */
     public ReferenceStore createQueueReferenceStore(ActiveMQQueue destination) 
throws IOException;
 
     /**
      * Factory method to create a new topic message store with the given 
destination name
+     * @param destination
+     * @return  the TopicRefererenceStore
+     * @throws IOException 
      */
     public TopicReferenceStore createTopicReferenceStore(ActiveMQTopic 
destination) throws IOException;
 
+       /**
+        * @return Set of File ids in use
+        * @throws IOException
+        */
        public Set<Integer> getReferenceFileIdsInUse() throws IOException;
     
     /**
@@ -60,5 +73,19 @@
      *
      */
     public void recoverState() throws IOException;
+    
+    /**
+     * Save prepared transactions
+     * @param map
+     * @throws IOException
+     */
+    public void savePreparedState(Map<TransactionId, AMQTx> map)throws 
IOException;
+    
+    /**
+     * 
+     * @return saved prepared transactions
+     * @throws IOException
+     */
+    public Map<TransactionId, AMQTx> retrievePreparedState() throws 
IOException;
 
 }