[camel] branch master updated: CAMEL-16295: fix aggregation when in transacted route (#5214)

[davsclaus]

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


The following commit(s) were added to refs/heads/master by this push:
     new 5999704  CAMEL-16295: fix aggregation when in transacted route (#5214)
5999704 is described below

commit 5999704e8ff7b39c94fbf63da995d9aa6e9836fa
Author: Tom Cassimon <tom.cassi...@tcke.be>
AuthorDate: Mon Mar 15 18:25:35 2021 +0100

    CAMEL-16295: fix aggregation when in transacted route (#5214)
    
    Co-authored-by: catom1 <tom.cassi...@argenta.be>
---
 .../java/org/apache/camel/processor/MulticastProcessor.java    | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/MulticastProcessor.java
 
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/MulticastProcessor.java
index 412368b..d23464a 100644
--- 
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/MulticastProcessor.java
+++ 
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/MulticastProcessor.java
@@ -587,11 +587,13 @@ public class MulticastProcessor extends 
AsyncProcessorSupport
                 return false;
             }
 
-            // accept the exchange as a result
-            completion.submit(exchangeResult -> 
exchangeResult.accept(exchange));
+            completion.submit(exchangeResult -> {
+                // accept the exchange as a result
+                exchangeResult.accept(exchange);
 
-            // aggregate exchanges if any
-            aggregate();
+                // aggregate exchanges if any
+                aggregate();
+            });
 
             // next step
             return true;