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 2016/11/24 18:47:46 UTC
camel git commit: CAMEL 10272: Fixed few comments
Repository: camel
Updated Branches:
refs/heads/master ccd85d2de -> f0821d4aa
CAMEL 10272: Fixed few comments
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f0821d4a
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f0821d4a
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f0821d4a
Branch: refs/heads/master
Commit: f0821d4aa2542e677a7c58e9f8f5e633fd4e2f62
Parents: ccd85d2
Author: aldettinger <al...@gmail.com>
Authored: Thu Nov 24 19:00:02 2016 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Nov 24 19:47:39 2016 +0100
----------------------------------------------------------------------
.../java/org/apache/camel/processor/MulticastProcessor.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/f0821d4a/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java b/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
index f30e900..5c5b361 100644
--- a/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
+++ b/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
@@ -304,10 +304,9 @@ public class MulticastProcessor extends ServiceSupport implements AsyncProcessor
completion.submit(new Callable<Exchange>() {
public Exchange call() throws Exception {
- // only start the aggregation task when the task is being executed to avoid staring
- // the aggregation task to early and pile up too many threads
+ // start the aggregation task at this stage only in order not to pile up too many threads
if (aggregationTaskSubmitted.compareAndSet(false, true)) {
- // but only submit the task once
+ // but only submit the aggregation task once
aggregateExecutorService.submit(aggregateOnTheFlyTask);
}