activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r557386 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ReferenceStoreAdapter.java
Date Wed, 18 Jul 2007 20:31:09 GMT
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;
 
 }



Mime
View raw message