CAMEL-8010:Included onSubmitCompletion in the lock section to prevent race condiditon
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/203fcf4d Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/203fcf4d Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/203fcf4d Branch: refs/heads/master Commit: 203fcf4d9b625cc4ee289e6bc5f21407b66e5e60 Parents: 45403da Author: Rajithamol <[email protected]> Authored: Fri Aug 18 15:34:41 2017 -0400 Committer: Andrea Cosentino <[email protected]> Committed: Thu Aug 24 11:18:47 2017 +0200 ---------------------------------------------------------------------- .../org/apache/camel/processor/aggregate/AggregateProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/203fcf4d/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java b/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java index 236665e..e438543 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java @@ -346,7 +346,7 @@ public class AggregateProcessor extends ServiceSupport implements AsyncProcessor lock.lock(); try { aggregated = doAggregation(key, copy); - // we are completed so do that work outside the lock + // we are completed so submit to completion if (aggregated != null) { for (Exchange agg : aggregated) { onSubmitCompletion(key, agg);
