Repository: ode Updated Branches: refs/heads/ode-1.3.x 7941dbd67 -> 9d9cff2bd
ODE-1065: pmapi enhanced to include myRole endpoints in process-info Project: http://git-wip-us.apache.org/repos/asf/ode/repo Commit: http://git-wip-us.apache.org/repos/asf/ode/commit/9d9cff2b Tree: http://git-wip-us.apache.org/repos/asf/ode/tree/9d9cff2b Diff: http://git-wip-us.apache.org/repos/asf/ode/diff/9d9cff2b Branch: refs/heads/ode-1.3.x Commit: 9d9cff2bd68be9b5b227f139c316bb3eeccc13ae Parents: 7941dbd Author: sathwik <[email protected]> Authored: Thu Oct 13 17:25:15 2016 +0530 Committer: sathwik <[email protected]> Committed: Thu Oct 13 17:25:15 2016 +0530 ---------------------------------------------------------------------- .../bpel/engine/ProcessAndInstanceManagementImpl.java | 14 ++++++++++++++ bpel-schemas/src/main/xsd/pmapi.xsd | 5 +++++ 2 files changed, 19 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ode/blob/9d9cff2b/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 10202f2..207d3f0 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 @@ -930,6 +930,20 @@ public class ProcessAndInstanceManagementImpl implements InstanceManagement, Pro if (pepr != null) { TEndpointReferences.EndpointRef epr = eprs.addNewEndpointRef(); + epr.setPartnerLink(oplink.name); + epr.setPartnerRole(oplink.partnerRoleName); + Document eprNodeDoc = epr.getDomNode().getOwnerDocument(); + epr.getDomNode().appendChild(eprNodeDoc.importNode(pepr.toXML().getDocumentElement(), true)); + } + } + if (oplink.hasMyRole()) { + EndpointReference pepr = _server._engine._activeProcesses.get(pconf.getProcessId()) + .getInitialMyRoleEPR(oplink); + + if (pepr != null) { + TEndpointReferences.EndpointRef epr = eprs.addNewEndpointRef(); + epr.setPartnerLink(oplink.name); + epr.setMyRole(oplink.myRoleName); Document eprNodeDoc = epr.getDomNode().getOwnerDocument(); epr.getDomNode().appendChild(eprNodeDoc.importNode(pepr.toXML().getDocumentElement(), true)); } http://git-wip-us.apache.org/repos/asf/ode/blob/9d9cff2b/bpel-schemas/src/main/xsd/pmapi.xsd ---------------------------------------------------------------------- diff --git a/bpel-schemas/src/main/xsd/pmapi.xsd b/bpel-schemas/src/main/xsd/pmapi.xsd index c3572d3..dc66ed5 100644 --- a/bpel-schemas/src/main/xsd/pmapi.xsd +++ b/bpel-schemas/src/main/xsd/pmapi.xsd @@ -406,6 +406,11 @@ <documentation>Name of the partner role this endpoint reference is associated with.</documentation> </annotation> </attribute> + <attribute name="my-role" type="xs:string"> + <annotation> + <documentation>Name of the my role this endpoint reference is associated with.</documentation> + </annotation> + </attribute> </complexType> </element> </sequence>
