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

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

Author: mark.little at jboss.com
Date: 2007-01-29 16:45:52 -0500 (Mon, 29 Jan 2007)
New Revision: 9082

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

Modified: labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/jca/XATerminatorImple.java
===================================================================
--- labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/jca/XATerminatorImple.java	2007-01-29 21:43:52 UTC (rev 9081)
+++ labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/jca/XATerminatorImple.java	2007-01-29 21:45:52 UTC (rev 9082)
@@ -250,7 +250,10 @@
 					
 					if (uid.notEquals(Uid.nullUid()))
 					{
-						values.push(uid);
+						TransactionImple tx = TxImporter.recoverTransaction(uid);
+						
+						if (tx != null)
+							values.push(tx);
 					}
 					else
 						finished = true;
@@ -265,9 +268,9 @@
 								
 					while (!values.empty())
 					{
-						Uid id = (Uid) values.pop();
+						com.arjuna.ats.internal.jta.transaction.arjunacore.subordinate.jca.TransactionImple tx = (com.arjuna.ats.internal.jta.transaction.arjunacore.subordinate.jca.TransactionImple) values.pop();
 						
-						indoubt[index] = new XidImple(id);
+						indoubt[index] = tx.baseXid();
 					}
 				}
 			}