CAMEL-9250: Configure AllowUseOriginalMessage to be disabled by default if not in use.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/df9427fc Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/df9427fc Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/df9427fc Branch: refs/heads/master Commit: df9427fc13f33c878f152ebcaea68acae84d5ace Parents: 5465035 Author: Claus Ibsen <davscl...@apache.org> Authored: Sat May 7 11:51:00 2016 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sat May 7 11:51:00 2016 +0200 ---------------------------------------------------------------------- .../org/apache/camel/model/OnExceptionDefinition.java | 10 ++++++++++ 1 file changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/df9427fc/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java b/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java index f7c06c5..9ed6ebe 100644 --- a/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java +++ b/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java @@ -194,6 +194,11 @@ public class OnExceptionDefinition extends ProcessorDefinition<OnExceptionDefini // must validate configuration before creating processor validateConfiguration(); + if (useOriginalMessagePolicy != null && useOriginalMessagePolicy) { + // ensure allow original is turned on + routeContext.setAllowUseOriginalMessage(true); + } + // lets attach this on exception to the route error handler Processor child = createOutputsProcessor(routeContext); if (child != null) { @@ -215,6 +220,11 @@ public class OnExceptionDefinition extends ProcessorDefinition<OnExceptionDefini exceptionClasses = createExceptionClasses(routeContext.getCamelContext().getClassResolver()); } + if (useOriginalMessagePolicy != null && useOriginalMessagePolicy) { + // ensure allow original is turned on + routeContext.setAllowUseOriginalMessage(true); + } + // must validate configuration before creating processor validateConfiguration();
