You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by va...@apache.org on 2011/01/13 17:07:01 UTC
svn commit: r1058637 - in
/ode/branches/ode-1.3.5.x/bpel-runtime/src/main/java/org/apache/ode/bpel/engine:
BpelProcess.java BpelRuntimeContextImpl.java
Author: vanto
Date: Thu Jan 13 16:07:00 2011
New Revision: 1058637
URL: http://svn.apache.org/viewvc?rev=1058637&view=rev
Log:
less noise on the INFO log level.
Modified:
ode/branches/ode-1.3.5.x/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelProcess.java
ode/branches/ode-1.3.5.x/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelRuntimeContextImpl.java
Modified: ode/branches/ode-1.3.5.x/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelProcess.java
URL: http://svn.apache.org/viewvc/ode/branches/ode-1.3.5.x/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelProcess.java?rev=1058637&r1=1058636&r2=1058637&view=diff
==============================================================================
--- ode/branches/ode-1.3.5.x/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelProcess.java (original)
+++ ode/branches/ode-1.3.5.x/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelProcess.java Thu Jan 13 16:07:00 2011
@@ -926,7 +926,7 @@ public class BpelProcess {
// If we have a transaction, we do this in the current transaction
if(__log.isDebugEnabled()) __log.debug("Creating new process DAO for " + _pid + " (guid=" + _oprocess.guid + ")...");
createProcessDAO(_engine._contexts.dao.getConnection(), _pid, _pconf.getVersion(), _oprocess);
- if(__log.isInfoEnabled()) __log.info("Created new process DAO for " + _pid + " (guid=" + _oprocess.guid + ").");
+ if(__log.isDebugEnabled()) __log.debug("Created new process DAO for " + _pid + " (guid=" + _oprocess.guid + ").");
} else {
try {
_engine._contexts.scheduler.execTransaction(new Callable<Object>() {
@@ -952,7 +952,7 @@ public class BpelProcess {
private void bounceProcessDAOInDB(final BpelDAOConnection conn, final QName pid, final long version, final OProcess oprocess) {
if(__log.isDebugEnabled()) __log.debug("Creating new process DAO for " + pid + " (guid=" + oprocess.guid + ")...");
createProcessDAO(conn, pid, version, oprocess);
- if(__log.isInfoEnabled()) __log.info("Created new process DAO for " + pid + " (guid=" + oprocess.guid + ").");
+ if(__log.isDebugEnabled()) __log.debug("Created new process DAO for " + pid + " (guid=" + oprocess.guid + ").");
}
public int getInstanceInUseCount() {
@@ -983,7 +983,7 @@ public class BpelProcess {
for (String correlator : oprocess.getCorrelators()) {
newDao.addCorrelator(correlator);
}
- if(__log.isInfoEnabled()) __log.info("Created new process DAO for " + pid + " (guid=" + oprocess.guid + ")");
+ if(__log.isDebugEnabled()) __log.debug("Created new process DAO for " + pid + " (guid=" + oprocess.guid + ")");
}
} catch (BpelEngineException ex) {
throw ex;
Modified: ode/branches/ode-1.3.5.x/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelRuntimeContextImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/ode-1.3.5.x/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelRuntimeContextImpl.java?rev=1058637&r1=1058636&r2=1058637&view=diff
==============================================================================
--- ode/branches/ode-1.3.5.x/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelRuntimeContextImpl.java (original)
+++ ode/branches/ode-1.3.5.x/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelRuntimeContextImpl.java Thu Jan 13 16:07:00 2011
@@ -701,6 +701,14 @@ public class BpelRuntimeContextImpl impl
_dao.finishCompletion();
failOutstandingMessageExchanges();
+
+ _bpelProcess._engine._contexts.scheduler.registerSynchronizer(new Scheduler.Synchronizer() {
+ public void afterCompletion(boolean success) {
+ }
+ public void beforeCompletion() {
+ _dao.delete(_bpelProcess.getCleanupCategories(false), false);
+ }
+ });
}
public void registerTimer(TimerResponseChannel timerChannel, Date timeToFire) {