ODE-1064: Iterate over all Partnerlinks containing myRole to indenty the correct portType
Project: http://git-wip-us.apache.org/repos/asf/ode/repo Commit: http://git-wip-us.apache.org/repos/asf/ode/commit/7dc074d7 Tree: http://git-wip-us.apache.org/repos/asf/ode/tree/7dc074d7 Diff: http://git-wip-us.apache.org/repos/asf/ode/diff/7dc074d7 Branch: refs/heads/master Commit: 7dc074d7be68bd41121c10a804aab066d050e30f Parents: 7fce22a Author: sathwik <[email protected]> Authored: Wed Jun 28 16:27:49 2017 +0530 Committer: sathwik <[email protected]> Committed: Wed Jun 28 16:27:49 2017 +0530 ---------------------------------------------------------------------- .../main/java/org/apache/ode/bpel/engine/BpelProcess.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ode/blob/7dc074d7/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelProcess.java ---------------------------------------------------------------------- diff --git a/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelProcess.java b/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelProcess.java index fad7e86..1dfbc94 100644 --- a/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelProcess.java +++ b/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelProcess.java @@ -414,10 +414,12 @@ public class BpelProcess { PartnerLinkMyRoleImpl target = null; for (Map.Entry<PartnerLinkMyRoleImpl,Endpoint> e : getEndpointToMyRoleMap().entrySet()) { if (e.getValue().serviceName.equals(mex.getServiceName())) { - // First one is fine as we're only interested in the portType and operation here and - // even if a process has 2 myrole partner links target = e.getKey(); - break; + //Multiple partnerlinks with myRole defined under the same service endpoint requires + // iteration to identify the portType, which contains the operation + if(target._plinkDef.getMyRoleOperation(mex.getOperationName()) != null) { + break; + } } } if (target != null) {
