[jboss-cvs] JBossAS SVN: r63569 - trunk/transaction/src/main/org/jboss/tm.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Tue Jun 19 07:21:16 EDT 2007
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
*
More information about the jboss-cvs-commits
mailing list