[jboss-cvs] JBossAS SVN: r71460 - branches/JBPAPP_4_2_0_GA_CP/connector/src/main/org/jboss/resource/connectionmanager.

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

Author: vicky.kak at jboss.com
Date: 2008-03-31 05:14:23 -0400 (Mon, 31 Mar 2008)
New Revision: 71460

Modified:
   branches/JBPAPP_4_2_0_GA_CP/connector/src/main/org/jboss/resource/connectionmanager/BaseConnectionManager2.java
Log:
[JBPAPP-662]Add a mechanism to check whether the thread associated transaction is no longer in a runnable state

Modified: branches/JBPAPP_4_2_0_GA_CP/connector/src/main/org/jboss/resource/connectionmanager/BaseConnectionManager2.java
===================================================================
--- branches/JBPAPP_4_2_0_GA_CP/connector/src/main/org/jboss/resource/connectionmanager/BaseConnectionManager2.java	2008-03-31 09:13:52 UTC (rev 71459)
+++ branches/JBPAPP_4_2_0_GA_CP/connector/src/main/org/jboss/resource/connectionmanager/BaseConnectionManager2.java	2008-03-31 09:14:23 UTC (rev 71460)
@@ -88,7 +88,8 @@
          BaseConnectionManager2MBean,
          ConnectionCacheListener,
          ConnectionListenerFactory,
-         TransactionTimeoutConfiguration
+         TransactionTimeoutConfiguration,
+         JTATransactionChecker
 {
    /**
     * Note that this copy has a trailing / unlike the original in
@@ -232,6 +233,11 @@
       throw new NotImplementedException("NYI: getTransactionTimeout()");
    }
 
+   public void checkTransactionActive() throws RollbackException, SystemException
+   {
+      // Nothing
+   }
+   
    //ServiceMBeanSupport
 
    protected void startService() throws Exception
@@ -820,7 +826,8 @@
          implements
             ConnectionManager,
             Serializable,
-            TransactionTimeoutConfiguration
+            TransactionTimeoutConfiguration,
+            JTATransactionChecker
    {
       static final long serialVersionUID = -528322728929261214L;
 
@@ -866,6 +873,18 @@
          }
       }
 
+      public void checkTransactionActive() throws RollbackException, SystemException
+      {
+         try
+         {
+            getCM().checkTransactionActive();
+         }
+         catch (ResourceException e)
+         {
+            throw new NestedRuntimeException("Unable to retrieve connection manager", e);
+         }
+      }
+      
       private BaseConnectionManager2 getCM() throws ResourceException
       {
          if (realCm == null)