You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by mr...@apache.org on 2008/08/18 19:43:39 UTC
svn commit: r686831 -
/ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
Author: mriou
Date: Mon Aug 18 10:43:39 2008
New Revision: 686831
URL: http://svn.apache.org/viewvc?rev=686831&view=rev
Log:
Transactions boundaries logging.
Modified:
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
Modified: ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java?rev=686831&r1=686830&r2=686831&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java (original)
+++ ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java Mon Aug 18 10:43:39 2008
@@ -165,6 +165,7 @@
public <T> T execTransaction(Callable<T> transaction) throws Exception, ContextException {
try {
+ if (__log.isDebugEnabled()) __log.debug("Beginning a new transaction");
_txm.begin();
} catch (Exception ex) {
String errmsg = "Internal Error, could not begin transaction.";
@@ -178,10 +179,13 @@
} catch (Exception ex) {
throw ex;
} finally {
- if (success)
+ if (success) {
+ if (__log.isDebugEnabled()) __log.debug("Commiting...");
_txm.commit();
- else
+ } else {
+ if (__log.isDebugEnabled()) __log.debug("Rollbacking...");
_txm.rollback();
+ }
}
}