You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by rr...@apache.org on 2010/04/07 17:25:22 UTC
svn commit: r931587 -
/ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java
Author: rr
Date: Wed Apr 7 15:25:22 2010
New Revision: 931587
URL: http://svn.apache.org/viewvc?rev=931587&view=rev
Log:
Shutdown processDefReaper thread on BpelServer stop.
Modified:
ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java
Modified: ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java?rev=931587&r1=931586&r2=931587&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java Wed Apr 7 15:25:22 2010
@@ -108,6 +108,7 @@ public class BpelServerImpl implements B
private boolean _hydrationLazy;
private int _hydrationLazyMinimumSize;
private int _migrationTransactionTimeout;
+ private Thread processDefReaper;
BpelEngineImpl _engine;
protected BpelDatabase _db;
@@ -164,10 +165,9 @@ public class BpelServerImpl implements B
_state = State.RUNNING;
__log.info(__msgs.msgServerStarted());
if (_dehydrationPolicy != null) {
- Thread thread = new Thread(new ProcessDefReaper(), "Dehydrator");
- thread.setDaemon(true);
- thread.start();
-
+ processDefReaper = new Thread(new ProcessDefReaper(), "Dehydrator");
+ processDefReaper.setDaemon(true);
+ processDefReaper.start();
}
} finally {
_mngmtLock.writeLock().unlock();
@@ -221,6 +221,8 @@ public class BpelServerImpl implements B
__log.debug("BPEL SERVER STOPPING");
+ processDefReaper.interrupt();
+ processDefReaper = null;
_contexts.scheduler.stop();
_engine = null;
_state = State.INIT;
@@ -478,7 +480,7 @@ public class BpelServerImpl implements B
}
}
} catch (InterruptedException e) {
- __log.info(e);
+ __log.debug(e);
}
}
}