[camel] branch camel-3.7.x updated: CAMEL-16295: split with AggregationStrategy is ignored when using transacted

[da...@apache.org]

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

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


The following commit(s) were added to refs/heads/camel-3.7.x by this push:
     new 164f0cb  CAMEL-16295: split with AggregationStrategy is ignored when using transacted
164f0cb is described below

commit 164f0cb1a54476484ada261092591c24c5b8bc5a
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Mar 3 15:45:08 2021 +0100

    CAMEL-16295: split with AggregationStrategy is ignored when using transacted
---
 .../src/main/java/org/apache/camel/processor/MulticastProcessor.java   | 3 +++
 1 file changed, 3 insertions(+)

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 948f514..254b2da 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
@@ -586,6 +586,9 @@ public class MulticastProcessor extends AsyncProcessorSupport
                 return false;
             }
 
+            // accept the exchange as a result
+            completion.submit(exchangeResult -> exchangeResult.accept(exchange));
+
             // aggregate exchanges if any
             aggregate();