Author: seanahn
Date: Tue Feb 17 19:29:21 2009
New Revision: 745208
URL: http://svn.apache.org/viewvc?rev=745208&view=rev
Log:
ODE-507, OutstandingRequestManager(ExecutionQueueImpl serialization) failed
when ODE loaded in db mode
Modified:
ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelEngineImpl.java
Modified:
ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelEngineImpl.java
URL:
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelEngineImpl.java?rev=745208&r1=745207&r2=745208&view=diff
==============================================================================
---
ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelEngineImpl.java
(original)
+++
ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelEngineImpl.java
Tue Feb 17 19:29:21 2009
@@ -19,9 +19,6 @@
package org.apache.ode.bpel.engine;
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.ObjectOutputStream;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
@@ -29,7 +26,6 @@
import java.util.List;
import java.util.Map;
import java.util.Random;
-import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;
import javax.wsdl.Operation;
@@ -93,9 +89,6 @@
private static final Messages __msgs =
MessageBundle.getMessages(Messages.class);
- /** Maximum number of tries for async jobs. */
- private static final int MAX_RETRIES = 3;
-
/** Active processes, keyed by process id. */
final HashMap<QName, BpelProcess> _activeProcesses = new HashMap<QName,
BpelProcess>();
@@ -330,7 +323,9 @@
public void onScheduledJob(Scheduler.JobInfo jobInfo) throws
Scheduler.JobProcessorException {
final WorkEvent we = new WorkEvent(jobInfo.jobDetail);
- // We lock the instance to prevent concurrent transactions and prevent
unnecessary rollbacks,
+ if( __log.isTraceEnabled() ) __log.trace("[JOB] onScheduledJob " +
jobInfo + "" + we.getIID());
+
+ // We lock the instance to prevent concurrent transactions and prevent
unnecessary rollbacks,
// Note that we don't want to wait too long here to get our lock,
since we are likely holding
// on to scheduler's locks of various sorts.
try {
