You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by bo...@apache.org on 2007/03/08 23:45:41 UTC
svn commit: r516211 -
/incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java
Author: boisvert
Date: Thu Mar 8 14:45:40 2007
New Revision: 516211
URL: http://svn.apache.org/viewvc?view=rev&rev=516211
Log:
Fix process instance summary stats
Modified:
incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java
Modified: incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java?view=diff&rev=516211&r1=516210&r2=516211
==============================================================================
--- incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java (original)
+++ incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java Thu Mar 8 14:45:40 2007
@@ -320,8 +320,7 @@
return null;
for (ActivityRecoveryDAO recovery : instance.getActivityRecoveries()) {
if (recovery.getActivityId() == aid) {
- BpelProcess process = _server._engine._activeProcesses.get(instance.getProcess()
- .getProcessId());
+ BpelProcess process = _server._engine._activeProcesses.get(instance.getProcess().getProcessId());
if (process != null) {
process.recoverActivity(instance, recovery.getChannel(), aid, action, null);
break;
@@ -654,7 +653,7 @@
if (files != null)
genDocumentInfo(docinfo, files.toArray(new File[files.size()]), true);
else if (__log.isDebugEnabled())
- __log.debug("fillProcessInfo: No files for " + pconf.getProcessId() + " !!!");
+ __log.debug("fillProcessInfo: No files for " + pconf.getProcessId());
if (custom.includeProcessProperties()) {
TProcessProperties properties = info.addNewProperties();
@@ -730,8 +729,8 @@
ProcessConf pconf) {
instances.setState(state);
String queryStatus = InstanceFilter.StatusKeys.valueOf(state.toString()).toString().toLowerCase();
- final InstanceFilter instanceFilter = new InstanceFilter("status=" + queryStatus + " name="
- + pconf.getProcessId().getLocalPart() + " namespace=" + pconf.getProcessId().getNamespaceURI());
+ final InstanceFilter instanceFilter = new InstanceFilter("status=" + queryStatus
+ + " pid="+ pconf.getProcessId());
int count = dbexec(new BpelDatabase.Callable<Integer>() {
@@ -745,8 +744,8 @@
private void getInstanceSummaryActivityFailure(final TInstanceSummary summary, ProcessConf pconf) {
String queryStatus = InstanceFilter.StatusKeys.valueOf(TInstanceStatus.ACTIVE.toString()).toString()
.toLowerCase();
- final InstanceFilter instanceFilter = new InstanceFilter("status=" + queryStatus + " name="
- + pconf.getProcessId().getLocalPart() + " namespace=" + pconf.getProcessId().getNamespaceURI());
+ final InstanceFilter instanceFilter = new InstanceFilter("status=" + queryStatus
+ + " pid="+ pconf.getProcessId());
dbexec(new BpelDatabase.Callable<Void>() {
public Void run(BpelDAOConnection conn) throws Exception {