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 {
