You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by sa...@apache.org on 2016/10/13 12:44:47 UTC
ode git commit: ODE-1065: pmapi enhanced to include myRole endpoints
in process-info
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 <sa...@apache.org>
Authored: Thu Oct 13 17:25:15 2016 +0530
Committer: sathwik <sa...@apache.org>
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>