This is an automated email from the ASF dual-hosted git repository. apupier pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit c96a268d7bdf47156f1b102dcfbfba98e6bfe3ab Author: smjain <[email protected]> AuthorDate: Thu Sep 24 08:31:25 2026 +0530 CAMEL-24959: camel-core - Make doDoneNoMorePairs private It is only called by MulticastReactiveTask, which has to call it with super. as a private method is not inherited. Co-Authored-By: Claude Opus 5.5 <[email protected]> --- .../src/main/java/org/apache/camel/processor/MulticastProcessor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 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 cc0863fe8ddb..b42093241549 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 @@ -527,7 +527,7 @@ public class MulticastProcessor extends BaseProcessorSupport * still be in progress, so mark all as sent, and only be done when they are all aggregated (the transacted task * handles the same case since CAMEL-21114). */ - protected void doDoneNoMorePairs() { + private void doDoneNoMorePairs() { Lock lock = this.lock; lock.lock(); try { @@ -661,7 +661,7 @@ public class MulticastProcessor extends BaseProcessorSupport // Get next processor exchange pair to sent, skipping null ones ProcessorExchangePair pair = getNextProcessorExchangePair(); if (pair == null) { - doDoneNoMorePairs(); + super.doDoneNoMorePairs(); return; }
