Repository: ode Updated Branches: refs/heads/ode-1.3.x 4ca976421 -> 1e141c2de
add correlation set info to process instance info document. Project: http://git-wip-us.apache.org/repos/asf/ode/repo Commit: http://git-wip-us.apache.org/repos/asf/ode/commit/8f5936a7 Tree: http://git-wip-us.apache.org/repos/asf/ode/tree/8f5936a7 Diff: http://git-wip-us.apache.org/repos/asf/ode/diff/8f5936a7 Branch: refs/heads/ode-1.3.x Commit: 8f5936a7c8effe292771429f5e82a68d9c406250 Parents: 4ca9764 Author: Tammo van Lessen <[email protected]> Authored: Sun Feb 1 23:28:34 2015 +0100 Committer: Tammo van Lessen <[email protected]> Committed: Wed Feb 11 13:41:38 2015 +0100 ---------------------------------------------------------------------- .../ode/bpel/engine/ProcessAndInstanceManagementImpl.java | 10 ++++++++++ 1 file changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ode/blob/8f5936a7/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java ---------------------------------------------------------------------- diff --git a/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java b/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java index 9523121..d58bef1 100644 --- a/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java +++ b/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java @@ -23,6 +23,7 @@ import java.io.ByteArrayOutputStream; import java.io.File; import java.text.ParseException; import java.util.ArrayList; +import java.util.Arrays; import java.util.Calendar; import java.util.Collection; import java.util.Collections; @@ -786,6 +787,15 @@ public class ProcessAndInstanceManagementImpl implements InstanceManagement, Pro throw new InstanceNotFoundException("InstanceNotFoundException " + iid); // TODO: deal with "ERROR" state information. fillInstanceInfo(ii, instance); + Map<Long, Collection<CorrelationSetDAO>> icsets = conn.getCorrelationSets(Arrays.asList(new ProcessInstanceDAO[] { instance })); + Collection<CorrelationSetDAO> csets = icsets.get(instance.getInstanceId()); + if (csets != null) { + for (CorrelationSetDAO cset: csets) { + Map<QName, String> props = cset.getProperties(); + fillProperties(ii, instance, props); + } + } + return ret; }
