[jboss-svn-commits] JBL Code SVN: r9087 - labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/jca.

jboss-svn-commits at lists.jboss.org jboss-svn-commits at lists.jboss.org
Mon Jan 29 17:06:19 EST 2007


Author: mark.little at jboss.com
Date: 2007-01-29 17:06:18 -0500 (Mon, 29 Jan 2007)
New Revision: 9087

Modified:
   labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/jca/TxImporter.java
Log:
Added recovery support.

Modified: labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/jca/TxImporter.java
===================================================================
--- labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/jca/TxImporter.java	2007-01-29 22:00:07 UTC (rev 9086)
+++ labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/jca/TxImporter.java	2007-01-29 22:06:18 UTC (rev 9087)
@@ -37,6 +37,7 @@
 
 import com.arjuna.ats.arjuna.common.Uid;
 import com.arjuna.ats.internal.jta.transaction.arjunacore.subordinate.jca.TransactionImple;
+import com.arjuna.ats.jta.xa.XidImple;
 
 public class TxImporter
 {
@@ -85,7 +86,7 @@
 		{	
 			imported = new TransactionImple(timeout, xid);
 			
-			_transactions.put(xid, imported);
+			_transactions.put(new XidImple(xid), imported);
 		}
 		
 		return imported;
@@ -144,7 +145,7 @@
 		if (xid == null)
 			throw new IllegalArgumentException();
 		
-		return (TransactionImple) _transactions.get(xid);
+		return (TransactionImple) _transactions.get(new XidImple(xid));
 	}
 	
 	/**
@@ -160,7 +161,7 @@
 		if (xid == null)
 			throw new IllegalArgumentException();
 		
-		_transactions.remove(xid);
+		_transactions.remove(new XidImple(xid));
 	}
 	
 	private static HashMap _transactions = new HashMap();




More information about the jboss-svn-commits mailing list