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 <sath...@apache.org>
Authored: Thu Oct 13 17:25:15 2016 +0530
Committer: sathwik <sath...@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>

Reply via email to