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 2007/02/06 23:12:35 UTC
svn commit: r504327 - in
/incubator/ode/trunk/bpel-scheduler-quartz/src/main/java/org/apache/ode/bpel/scheduler/quartz:
JTAJobRunShell.java QuartzSchedulerImpl.java
Author: mriou
Date: Tue Feb 6 14:12:34 2007
New Revision: 504327
URL: http://svn.apache.org/viewvc?view=rev&rev=504327
Log:
More tx logging.
Modified:
incubator/ode/trunk/bpel-scheduler-quartz/src/main/java/org/apache/ode/bpel/scheduler/quartz/JTAJobRunShell.java
incubator/ode/trunk/bpel-scheduler-quartz/src/main/java/org/apache/ode/bpel/scheduler/quartz/QuartzSchedulerImpl.java
Modified: incubator/ode/trunk/bpel-scheduler-quartz/src/main/java/org/apache/ode/bpel/scheduler/quartz/JTAJobRunShell.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/bpel-scheduler-quartz/src/main/java/org/apache/ode/bpel/scheduler/quartz/JTAJobRunShell.java?view=diff&rev=504327&r1=504326&r2=504327
==============================================================================
--- incubator/ode/trunk/bpel-scheduler-quartz/src/main/java/org/apache/ode/bpel/scheduler/quartz/JTAJobRunShell.java (original)
+++ incubator/ode/trunk/bpel-scheduler-quartz/src/main/java/org/apache/ode/bpel/scheduler/quartz/JTAJobRunShell.java Tue Feb 6 14:12:34 2007
@@ -19,16 +19,18 @@
package org.apache.ode.bpel.scheduler.quartz;
-import javax.transaction.Status;
-import javax.transaction.SystemException;
-import javax.transaction.TransactionManager;
-
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.core.JobRunShell;
import org.quartz.core.JobRunShellFactory;
import org.quartz.core.SchedulingContext;
+import javax.transaction.Status;
+import javax.transaction.SystemException;
+import javax.transaction.TransactionManager;
+
/**
* A riff on the Quartz JTA implementation that dispenses with the use
* of the UserTransaction interface, and instead goes direct to the source,
@@ -37,6 +39,8 @@
*/
public class JTAJobRunShell extends JobRunShell {
+ protected final Log __log = LogFactory.getLog(getClass());
+
/*
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*
@@ -72,6 +76,7 @@
protected void begin() throws SchedulerException {
try {
+ if (__log.isDebugEnabled()) __log.debug("Starting transaction.");
_txm.begin();
} catch (Exception nse) {
@@ -97,7 +102,7 @@
if (successfulExecution) {
try {
- log.debug("Committing UserTransaction.");
+ if (__log.isDebugEnabled()) __log.debug("Commiting transaction.");
_txm.commit();
} catch (Exception nse) {
throw new SchedulerException(
@@ -105,7 +110,7 @@
}
} else {
try {
- log.debug("Rolling-back UserTransaction.");
+ if (__log.isDebugEnabled()) __log.debug("Rollbacking transaction.");
_txm.rollback();
} catch (Exception nse) {
throw new SchedulerException(
Modified: incubator/ode/trunk/bpel-scheduler-quartz/src/main/java/org/apache/ode/bpel/scheduler/quartz/QuartzSchedulerImpl.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/bpel-scheduler-quartz/src/main/java/org/apache/ode/bpel/scheduler/quartz/QuartzSchedulerImpl.java?view=diff&rev=504327&r1=504326&r2=504327
==============================================================================
--- incubator/ode/trunk/bpel-scheduler-quartz/src/main/java/org/apache/ode/bpel/scheduler/quartz/QuartzSchedulerImpl.java (original)
+++ incubator/ode/trunk/bpel-scheduler-quartz/src/main/java/org/apache/ode/bpel/scheduler/quartz/QuartzSchedulerImpl.java Tue Feb 6 14:12:34 2007
@@ -221,6 +221,7 @@
public <T> T execTransaction(Callable<T> transaction) throws Exception, ContextException {
try {
+ if (__log.isDebugEnabled()) __log.debug("Starting transaction.");
begin();
} catch (Exception ex) {
String errmsg = "Failed to start transaction.";
@@ -236,6 +237,7 @@
} finally {
if (success)
try {
+ if (__log.isDebugEnabled()) __log.debug("Commiting transaction.");
commit();
} catch (Exception ex) {
String errmsg = "Failed to commit transaction.";