This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch ds in repository https://gitbox.apache.org/repos/asf/camel.git
commit c598a862f83df9632f0a72081f1ebd9a27438ec7 Author: Claus Ibsen <[email protected]> AuthorDate: Mon Dec 23 15:11:41 2024 +0100 camel-core: multicast/split EIP should remove internal exchange property for aggregation strategy if its no longer in use --- .../src/main/java/org/apache/camel/processor/MulticastProcessor.java | 4 ++++ 1 file changed, 4 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 f9514de06a1..3fd2143fdd8 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 @@ -1278,6 +1278,10 @@ public class MulticastProcessor extends AsyncProcessorSupport } // remove the strategy using this processor as the key map.remove(this); + // and remove map if its empty + if (map.isEmpty()) { + exchange.removeProperty(ExchangePropertyKey.AGGREGATION_STRATEGY); + } } /**
