[jboss-cvs] JBossAS SVN: r63569 - trunk/transaction/src/main/org/jboss/tm.

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

Author: dimitris at jboss.org
Date: 2007-06-19 07:21:16 -0400 (Tue, 19 Jun 2007)
New Revision: 63569

Modified:
   trunk/transaction/src/main/org/jboss/tm/TxUtils.java
Log:
Add utility methods.

Modified: trunk/transaction/src/main/org/jboss/tm/TxUtils.java
===================================================================
--- trunk/transaction/src/main/org/jboss/tm/TxUtils.java	2007-06-19 11:15:10 UTC (rev 63568)
+++ trunk/transaction/src/main/org/jboss/tm/TxUtils.java	2007-06-19 11:21:16 UTC (rev 63569)
@@ -67,9 +67,13 @@
 
    public static boolean isActive(Transaction tx)
    {
+      if (tx == null)
+         return false;
+      
       try
       {
-         return tx != null && (tx.getStatus() == Status.STATUS_ACTIVE);
+         int status = tx.getStatus();
+         return isActive(status);
       }
       catch (SystemException error)
       {
@@ -93,7 +97,8 @@
    {
       try
       {
-         return ut.getStatus() == Status.STATUS_ACTIVE;
+         int status = ut.getStatus();
+         return isActive(status);
       }
       catch (SystemException error)
       {
@@ -101,14 +106,20 @@
       }
    }
 
+   public static boolean isActive(int status)
+   {
+      return status == Status.STATUS_ACTIVE;
+   }
+   
    public static boolean isUncommitted(Transaction tx)
    {
+      if (tx == null)
+         return false;
+      
       try
       {
-         if (tx == null)
-            return false;
          int status = tx.getStatus();
-         return status == Status.STATUS_ACTIVE || status == Status.STATUS_MARKED_ROLLBACK;
+         return isUncommitted(status);
       }
       catch (SystemException error)
       {
@@ -128,16 +139,35 @@
       }
    }
 
+   public static boolean isUncommitted(UserTransaction ut)
+   {
+      try
+      {
+         int status = ut.getStatus();
+         return isUncommitted(status);
+         
+      }
+      catch (SystemException error)
+      {
+         throw new NestedRuntimeException(error);
+      }
+   }
+
+   public static boolean isUncommitted(int status)
+   {
+      return status == Status.STATUS_ACTIVE
+          || status == Status.STATUS_MARKED_ROLLBACK;
+   }
+   
    public static boolean isCompleted(Transaction tx)
    {
+      if (tx == null)
+         return true;
+      
       try
       {
-         if (tx == null)
-            return true;
          int status = tx.getStatus();
-         return status == Status.STATUS_COMMITTED
-             || status == Status.STATUS_ROLLEDBACK
-             || status == Status.STATUS_NO_TRANSACTION;
+         return isCompleted(status);
       }
       catch (SystemException error)
       {
@@ -162,9 +192,8 @@
       try
       {
          int status = ut.getStatus();
-         return status == Status.STATUS_COMMITTED
-             || status == Status.STATUS_ROLLEDBACK
-             || status == Status.STATUS_NO_TRANSACTION;
+         return isCompleted(status);
+         
       }
       catch (SystemException error)
       {
@@ -172,17 +201,22 @@
       }
    }
    
+   public static boolean isCompleted(int status)
+   {
+      return status == Status.STATUS_COMMITTED
+          || status == Status.STATUS_ROLLEDBACK
+          || status == Status.STATUS_NO_TRANSACTION;
+   }
+   
    public static boolean isRollback(Transaction tx)
    {
+      if (tx == null)
+         return false;
+      
       try
       {
-         if (tx == null)
-            return false;
-         
          int status = tx.getStatus();
-         return status == Status.STATUS_MARKED_ROLLBACK
-             || status == Status.STATUS_ROLLING_BACK
-             || status == Status.STATUS_ROLLEDBACK;
+         return isRollback(status);
       }
       catch (SystemException error)
       {
@@ -207,9 +241,7 @@
       try
       {
          int status = ut.getStatus();
-         return status == Status.STATUS_MARKED_ROLLBACK
-         	|| status == Status.STATUS_ROLLING_BACK
-         	|| status == Status.STATUS_ROLLEDBACK;
+         return isRollback(status);
       }
       catch (SystemException error)
       {
@@ -217,6 +249,13 @@
       }
    }
    
+   public static boolean isRollback(int status)
+   {
+      return status == Status.STATUS_MARKED_ROLLBACK
+          || status == Status.STATUS_ROLLING_BACK
+          || status == Status.STATUS_ROLLEDBACK;      
+   }
+   
    /**
     * Converts a tx Status index to a String
     *