[jboss-cvs] JBoss Messaging SVN: r1596 - branches/Branch_1_0_XARecovery/src/main/org/jboss/messaging/core/plugin/contract

[jboss-cvs-commits at lists.jboss.org]

Author: juha at jboss.org
Date: 2006-11-20 06:57:40 -0500 (Mon, 20 Nov 2006)
New Revision: 1596

Modified:
   branches/Branch_1_0_XARecovery/src/main/org/jboss/messaging/core/plugin/contract/PersistenceManager.java
Log:
Original patch (JBMessaging-407) with changed to persistence manager to handle recovery related queries.

Modified: branches/Branch_1_0_XARecovery/src/main/org/jboss/messaging/core/plugin/contract/PersistenceManager.java
===================================================================
--- branches/Branch_1_0_XARecovery/src/main/org/jboss/messaging/core/plugin/contract/PersistenceManager.java	2006-11-20 11:57:22 UTC (rev 1595)
+++ branches/Branch_1_0_XARecovery/src/main/org/jboss/messaging/core/plugin/contract/PersistenceManager.java	2006-11-20 11:57:40 UTC (rev 1596)
@@ -25,23 +25,33 @@
 
 import org.jboss.messaging.core.MessageReference;
 import org.jboss.messaging.core.tx.Transaction;
+import org.jboss.jms.server.plugin.contract.ChannelMapper;
 
 /**
  * The interface to the persistence manager
  *
  * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
  * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ * @author <a href="mailto:Konda.Madhu at uk.mizuho-sc.com">Madhu Konda</a>
+ *
  * @version <tt>1.1</tt>
  *
  * PersistenceManager.java,v 1.1 2006/02/22 17:33:42 timfox Exp
  */
 public interface PersistenceManager extends ServerPlugin
 {
-   /*
-    * Currently unused but will be used for XA recovery
-    */
    List retrievePreparedTransactions() throws Exception;
-      
+
+   ChannelMapper getChannelMapperReference();
+
+   long getMessageIdForRef(long transactionId) throws Exception;
+
+   long getMessageIdForAck(long transactionId) throws Exception;
+
+   long getChannelId(long transactionId) throws Exception;
+
+	void associateTxCallbackToPreparedTx(Transaction tx);
+
    void resetLoadedStatus(long channelID) throws Exception;
       
    void addReference(long channelID, MessageReference ref, Transaction tx) throws Exception;