This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch zip in repository https://gitbox.apache.org/repos/asf/camel.git
commit b29bd33fc8c1fa22a04f0df0cee4a1da0f2199a6 Author: Claus Ibsen <[email protected]> AuthorDate: Mon Sep 2 09:58:56 2024 +0200 CAMEL-21114: camel-zipfile - ZipSplitter with AggregationStrategy does not aggregate all splits in transacted mode. --- .../src/main/java/org/apache/camel/processor/MulticastProcessor.java | 5 ----- 1 file changed, 5 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 0cb99b16e79..5d254c1fbac 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 @@ -486,7 +486,6 @@ public class MulticastProcessor extends AsyncProcessorSupport } protected void aggregate() { - System.out.println("aggregate"); Lock lock = this.lock; if (lock.tryLock()) { try { @@ -688,10 +687,6 @@ public class MulticastProcessor extends AsyncProcessorSupport next = false; } } - // execute any pending tasks - // while (reactiveExecutor.executeFromQueue()) { - // System.out.println("pending work"); - // } // fail-safe to ensure we trigger done doDone(null, false); }
