Repository: ode Updated Branches: refs/heads/ode-1.3.x 6be91e10a -> 0342b4031
ODE-1048: Diabled MEX_MATCHER job Project: http://git-wip-us.apache.org/repos/asf/ode/repo Commit: http://git-wip-us.apache.org/repos/asf/ode/commit/0342b403 Tree: http://git-wip-us.apache.org/repos/asf/ode/tree/0342b403 Diff: http://git-wip-us.apache.org/repos/asf/ode/diff/0342b403 Branch: refs/heads/ode-1.3.x Commit: 0342b40316d8730900f9107c1d4dbbac1b33c226 Parents: 6be91e1 Author: sathwik <[email protected]> Authored: Sat Mar 5 11:16:25 2016 +0530 Committer: sathwik <[email protected]> Committed: Sat Mar 5 11:16:25 2016 +0530 ---------------------------------------------------------------------- .../java/org/apache/ode/bpel/engine/PartnerLinkMyRoleImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ode/blob/0342b403/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/PartnerLinkMyRoleImpl.java ---------------------------------------------------------------------- diff --git a/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/PartnerLinkMyRoleImpl.java b/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/PartnerLinkMyRoleImpl.java index 42dfd7a..d6a1ce0 100644 --- a/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/PartnerLinkMyRoleImpl.java +++ b/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/PartnerLinkMyRoleImpl.java @@ -292,7 +292,8 @@ public class PartnerLinkMyRoleImpl extends PartnerLinkRoleImpl { // No match, means we add message exchange to the queue. routing.correlator.enqueueMessage(mex.getDAO(), routing.wholeKeySet); - //Second matcher needs to be registered here + // Do we really need this? Check ODE-1048 +/* //Second matcher needs to be registered here JobDetails we = new JobDetails(); we.setType(JobType.MEX_MATCHER); we.setProcessId(_process.getPID()); @@ -303,6 +304,7 @@ public class PartnerLinkMyRoleImpl extends PartnerLinkRoleImpl { }else{ _process._engine._contexts.scheduler.schedulePersistedJob(we, null); } +*/ } } }
