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

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

Author: mark.little at jboss.com
Date: 2009-01-08 10:05:10 -0500 (Thu, 08 Jan 2009)
New Revision: 24607

Modified:
   labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/BaseTransaction.java
Log:
https://jira.jboss.org/jira/browse/JBTM-444

Modified: labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/BaseTransaction.java
===================================================================
--- labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/BaseTransaction.java	2009-01-08 14:54:00 UTC (rev 24606)
+++ labs/jbosstm/trunk/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/BaseTransaction.java	2009-01-08 15:05:10 UTC (rev 24607)
@@ -85,8 +85,7 @@
 			}
 		}
 
-
-		Integer value = (Integer) _timeouts.get(ThreadUtil.getThreadId());
+		Integer value = _timeouts.get();
 		int v = 0; // if not set then assume 0. What else can we do?
 
 		if (value != null)
@@ -219,13 +218,13 @@
 	{
 		if (seconds >= 0)
 		{
-			_timeouts.put(ThreadUtil.getThreadId(), new Integer(seconds));
+		    _timeouts.set(new Integer(seconds));
 		}
 	}
 
 	public int getTimeout() throws javax.transaction.SystemException
 	{
-		Integer value = (Integer) _timeouts.get(ThreadUtil.getThreadId());
+		Integer value = _timeouts.get();
 
 		if (value != null)
 		{
@@ -268,7 +267,7 @@
 			throw new javax.transaction.SystemException(e2.toString());
 		}
 		
-		Integer value = (Integer) _timeouts.get(ThreadUtil.getThreadId());
+		Integer value = _timeouts.get();
 		int v = 0; // if not set then assume 0. What else can we do?
 		
 		if (value != null)
@@ -303,7 +302,7 @@
 
 		if (theTransaction == null)
 			return;
-		else
+		else 
 		{
 			if ((theTransaction.getStatus() != javax.transaction.Status.STATUS_NO_TRANSACTION)
 					&& !_supportSubtransactions)
@@ -317,7 +316,7 @@
 
 	private static boolean _supportSubtransactions = false;
 
-	private static Hashtable _timeouts = new Hashtable();
+	private static ThreadLocal<Integer> _timeouts = new ThreadLocal<Integer>();
 
 	static
 	{