Repository: camel Updated Branches: refs/heads/camel-2.13.x 387f571cd -> 4ba6d4164 refs/heads/camel-2.14.x 34cd058ce -> ad73ccec9
CAMEL-8213: Fixed potential NPE in agg strategy. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4ba6d416 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4ba6d416 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4ba6d416 Branch: refs/heads/camel-2.13.x Commit: 4ba6d4164d3ca237d0e9f692bdfff9d1627b7389 Parents: 387f571 Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Jan 8 21:18:25 2015 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Jan 9 09:10:15 2015 +0100 ---------------------------------------------------------------------- .../processor/aggregate/UseOriginalAggregationStrategy.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/4ba6d416/camel-core/src/main/java/org/apache/camel/processor/aggregate/UseOriginalAggregationStrategy.java ---------------------------------------------------------------------- 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 d6b7059..764151f 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 @@ -44,7 +44,11 @@ public class UseOriginalAggregationStrategy implements AggregationStrategy { if (propagateException) { Exception exception = checkException(oldExchange, newExchange); if (exception != null) { - original.setException(exception); + if (original != null) { + original.setException(exception); + } else { + oldExchange.setException(exception); + } } } return original != null ? original : oldExchange;
