Author: mriou
Date: Mon Aug 18 10:49:51 2008
New Revision: 686834

URL: http://svn.apache.org/viewvc?rev=686834&view=rev
Log:
Merge from 1.x, preparation for Hibernate 3.3 upgrade and additional tx logging.

Modified:
    
ode/trunk/dao-hibernate/src/main/java/org/apache/ode/daohib/HibernateTransactionManagerLookup.java
    
ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java

Modified: 
ode/trunk/dao-hibernate/src/main/java/org/apache/ode/daohib/HibernateTransactionManagerLookup.java
URL: 
http://svn.apache.org/viewvc/ode/trunk/dao-hibernate/src/main/java/org/apache/ode/daohib/HibernateTransactionManagerLookup.java?rev=686834&r1=686833&r2=686834&view=diff
==============================================================================
--- 
ode/trunk/dao-hibernate/src/main/java/org/apache/ode/daohib/HibernateTransactionManagerLookup.java
 (original)
+++ 
ode/trunk/dao-hibernate/src/main/java/org/apache/ode/daohib/HibernateTransactionManagerLookup.java
 Mon Aug 18 10:49:51 2008
@@ -21,6 +21,7 @@
 import java.util.Properties;
 
 import javax.transaction.TransactionManager;
+import javax.transaction.Transaction;
 
 import org.hibernate.HibernateException;
 import org.hibernate.transaction.TransactionManagerLookup;
@@ -44,4 +45,8 @@
        public String getUserTransactionName() {
                return null;
        }
+
+    public Object getTransactionIdentifier(Transaction transaction) {
+        return transaction;
+    }
 }

Modified: 
ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
URL: 
http://svn.apache.org/viewvc/ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java?rev=686834&r1=686833&r2=686834&view=diff
==============================================================================
--- 
ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
 (original)
+++ 
ode/trunk/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
 Mon Aug 18 10:49:51 2008
@@ -137,6 +137,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.";
@@ -150,10 +151,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();
+            }
         }
     }
 


Reply via email to