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

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

Author: juha at jboss.org
Date: 2006-12-09 13:50:10 -0500 (Sat, 09 Dec 2006)
New Revision: 1743

Modified:
   branches/Branch_1_0/src/main/org/jboss/messaging/core/plugin/contract/PersistenceManager.java
Log:
Rewrite of patch JBMESSAGING-407. Simplifying requirements to PersistenceManager interface and removing unneeded methods.

Modified: branches/Branch_1_0/src/main/org/jboss/messaging/core/plugin/contract/PersistenceManager.java
===================================================================
--- branches/Branch_1_0/src/main/org/jboss/messaging/core/plugin/contract/PersistenceManager.java	2006-12-09 18:48:50 UTC (rev 1742)
+++ branches/Branch_1_0/src/main/org/jboss/messaging/core/plugin/contract/PersistenceManager.java	2006-12-09 18:50:10 UTC (rev 1743)
@@ -22,6 +22,7 @@
 package org.jboss.messaging.core.plugin.contract;
 
 import java.util.List;
+import java.util.Map;
 
 import org.jboss.messaging.core.MessageReference;
 import org.jboss.messaging.core.tx.Transaction;
@@ -33,6 +34,7 @@
  * @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>
+ * @author <a href="mailto:juha at jboss.org">Juha Lindfors</a>
  *
  * @version <tt>1.1</tt>
  *
@@ -42,16 +44,12 @@
 {
    List retrievePreparedTransactions() throws Exception;
 
-   ChannelMapper getChannelMapperReference();
+   ChannelMapper getChannels();
 
-   long getMessageIdForRef(long transactionId) throws Exception;
+   Map getMessageChannelPairForTx(long transactionId) throws Exception;
 
-   long getMessageIdForAck(long transactionId) throws Exception;
+   List getAcksForTx(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;
@@ -125,5 +123,4 @@
          return reliable;
       }
    }
-   
 }