Repository: camel Updated Branches: refs/heads/master ee5550732 -> 7f9ba0f04
CAMEL-5286: More flexible onCompletion allow to configure mode before/after consumer. And whether to use async/sync with thread pool or not. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/7f9ba0f0 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/7f9ba0f0 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/7f9ba0f0 Branch: refs/heads/master Commit: 7f9ba0f04fe095871d32d6334c617d3ce14f2e82 Parents: ee55507 Author: Claus Ibsen <davscl...@apache.org> Authored: Wed Aug 13 09:03:58 2014 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Wed Aug 13 09:03:58 2014 +0200 ---------------------------------------------------------------------- .../java/org/apache/camel/processor/OnCompletionProcessor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/7f9ba0f0/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java b/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java index b3cf250..b925c29 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java @@ -114,8 +114,8 @@ public class OnCompletionProcessor extends ServiceSupport implements AsyncProces } protected boolean isCreateCopy() { - // we need to create a correlated copy if we run in parallel mode - return executorService != null; + // we need to create a correlated copy if we run in parallel mode or is in after consumer mode (as the UoW would be done on the original exchange otherwise) + return executorService != null || afterConsumer; } /**
