svn commit: r686831 - /ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java

[mriou]

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();
+            }
         }
     }