(camel) branch sync-split updated: CAMEL-21671: camel-core: Split/Multicast EIP: Sync processing in parallel mode to avoid unbounded thread use, but to respect the thread pool limits from the EIP. Thanks to Soheila Esmaeili for unit test.

[davsclaus]

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

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


The following commit(s) were added to refs/heads/sync-split by this push:
     new 39e54c2feb6 CAMEL-21671: camel-core: Split/Multicast EIP: Sync 
processing in parallel mode to avoid unbounded thread use, but to respect the 
thread pool limits from the EIP. Thanks to Soheila Esmaeili for unit test.
39e54c2feb6 is described below

commit 39e54c2feb64db740d3fe22ce9e9a6f653a9b5c9
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Mar 3 11:01:17 2025 +0100

    CAMEL-21671: camel-core: Split/Multicast EIP: Sync processing in parallel 
mode to avoid unbounded thread use, but to respect the thread pool limits from 
the EIP. Thanks to Soheila Esmaeili for unit test.
---
 .../src/main/java/org/apache/camel/processor/MulticastProcessor.java     | 1 -
 1 file changed, 1 deletion(-)

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 ea13243477e..a2c51865862 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
@@ -186,7 +186,6 @@ public class MulticastProcessor extends 
AsyncProcessorSupport
     private final int cacheSize;
     private final Map<Processor, Processor> errorHandlers;
     private final boolean shareUnitOfWork;
-    private final AtomicInteger inflight = new AtomicInteger();
 
     public MulticastProcessor(CamelContext camelContext, Route route, 
Collection<Processor> processors) {
         this(camelContext, route, processors, null);