You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2024/09/02 08:25:01 UTC
(camel) 03/05: CAMEL-21114: camel-zipfile - ZipSplitter with AggregationStrategy does not aggregate all splits in transacted mode.
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 <cl...@gmail.com>
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);
}