You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2018/04/16 10:35:38 UTC

[camel] 02/02: CAMEL-12446: Splitter - Make it easier to turn off propgate exception

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit da4bda004dbca796bca7ebf4f697fbe7ba1fd0fa
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Mon Apr 16 12:19:20 2018 +0200

    CAMEL-12446: Splitter - Make it easier to turn off propgate exception
---
 .../camel/processor/aggregate/UseOriginalAggregationStrategy.java     | 4 ++++
 .../java/org/apache/camel/util/toolbox/AggregationStrategies.java     | 2 +-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/camel-core/src/main/java/org/apache/camel/processor/aggregate/UseOriginalAggregationStrategy.java b/camel-core/src/main/java/org/apache/camel/processor/aggregate/UseOriginalAggregationStrategy.java
index dbd60c5..5b3ac53 100644
--- a/camel-core/src/main/java/org/apache/camel/processor/aggregate/UseOriginalAggregationStrategy.java
+++ b/camel-core/src/main/java/org/apache/camel/processor/aggregate/UseOriginalAggregationStrategy.java
@@ -35,6 +35,10 @@ public class UseOriginalAggregationStrategy implements AggregationStrategy {
         this(null, true);
     }
 
+    public UseOriginalAggregationStrategy(boolean propagateException) {
+        this.propagateException = propagateException;
+    }
+
     public UseOriginalAggregationStrategy(Exchange original, boolean propagateException) {
         this.original = original;
         this.propagateException = propagateException;
diff --git a/camel-core/src/main/java/org/apache/camel/util/toolbox/AggregationStrategies.java b/camel-core/src/main/java/org/apache/camel/util/toolbox/AggregationStrategies.java
index ac68858..4952be1 100644
--- a/camel-core/src/main/java/org/apache/camel/util/toolbox/AggregationStrategies.java
+++ b/camel-core/src/main/java/org/apache/camel/util/toolbox/AggregationStrategies.java
@@ -77,7 +77,7 @@ public final class AggregationStrategies {
      * @see org.apache.camel.processor.aggregate.UseOriginalAggregationStrategy
      */
     public static AggregationStrategy useOriginal(boolean propagateException) {
-        return new UseOriginalAggregationStrategy(null, propagateException);
+        return new UseOriginalAggregationStrategy(propagateException);
     }
 
     /**

-- 
To stop receiving notification emails like this one, please contact
davsclaus@apache.org.