This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3a897f1ab8ab2cdbc15953b70760e5f602e27560 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Sat Mar 28 13:36:02 2026 +0000 (chores): fix SonarCloud S5993 in camel-core-processor Change public constructors of abstract classes to protected. Claude Code on behalf of Otavio R. Piske Co-Authored-By: Claude Sonnet 4.6 <[email protected]> --- .../camel/processor/BaseDelegateProcessorSupport.java | 2 +- .../org/apache/camel/processor/DelayProcessorSupport.java | 6 +++--- .../java/org/apache/camel/processor/PooledTaskFactory.java | 4 ++-- .../processor/errorhandler/RedeliveryErrorHandler.java | 14 ++++++++------ .../camel/processor/loadbalancer/WeightedLoadBalancer.java | 2 +- .../org/apache/camel/processor/saga/SagaProcessor.java | 4 ++-- 6 files changed, 17 insertions(+), 15 deletions(-) diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/BaseDelegateProcessorSupport.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/BaseDelegateProcessorSupport.java index 90fa29ff7580..52a5229fb72c 100644 --- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/BaseDelegateProcessorSupport.java +++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/BaseDelegateProcessorSupport.java @@ -24,7 +24,7 @@ import org.apache.camel.support.processor.DelegateAsyncProcessor; */ public abstract class BaseDelegateProcessorSupport extends DelegateAsyncProcessor { - public BaseDelegateProcessorSupport(Processor processor) { + protected BaseDelegateProcessorSupport(Processor processor) { super(processor); } diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/DelayProcessorSupport.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/DelayProcessorSupport.java index a5b9a4c78599..0854e4c05d53 100644 --- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/DelayProcessorSupport.java +++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/DelayProcessorSupport.java @@ -82,12 +82,12 @@ public abstract class DelayProcessorSupport extends BaseDelegateProcessorSupport } } - public DelayProcessorSupport(CamelContext camelContext, Processor processor) { + protected DelayProcessorSupport(CamelContext camelContext, Processor processor) { this(camelContext, processor, null, false); } - public DelayProcessorSupport(CamelContext camelContext, Processor processor, ScheduledExecutorService executorService, - boolean shutdownExecutorService) { + protected DelayProcessorSupport(CamelContext camelContext, Processor processor, ScheduledExecutorService executorService, + boolean shutdownExecutorService) { super(processor); this.camelContext = camelContext; this.executorService = executorService; diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/PooledTaskFactory.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/PooledTaskFactory.java index 56668838ccfa..30cfd2faa61d 100644 --- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/PooledTaskFactory.java +++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/PooledTaskFactory.java @@ -23,10 +23,10 @@ import org.apache.camel.support.PooledObjectFactorySupport; public abstract class PooledTaskFactory extends PooledObjectFactorySupport<PooledExchangeTask> implements PooledExchangeTaskFactory { - public PooledTaskFactory() { + protected PooledTaskFactory() { } - public PooledTaskFactory(Object source) { + protected PooledTaskFactory(Object source) { super(source); } diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryErrorHandler.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryErrorHandler.java index 63693b60dd37..2c154c122bae 100644 --- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryErrorHandler.java +++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryErrorHandler.java @@ -108,12 +108,14 @@ public abstract class RedeliveryErrorHandler extends ErrorHandlerSupport protected final Processor onPrepareProcessor; protected final Processor onExceptionProcessor; - public RedeliveryErrorHandler(CamelContext camelContext, Processor output, CamelLogger logger, - Processor redeliveryProcessor, RedeliveryPolicy redeliveryPolicy, Processor deadLetter, - String deadLetterUri, boolean deadLetterHandleNewException, boolean useOriginalMessagePolicy, - boolean useOriginalBodyPolicy, - Predicate retryWhile, ScheduledExecutorService executorService, Processor onPrepareProcessor, - Processor onExceptionProcessor) { + protected RedeliveryErrorHandler(CamelContext camelContext, Processor output, CamelLogger logger, + Processor redeliveryProcessor, RedeliveryPolicy redeliveryPolicy, Processor deadLetter, + String deadLetterUri, boolean deadLetterHandleNewException, + boolean useOriginalMessagePolicy, + boolean useOriginalBodyPolicy, + Predicate retryWhile, ScheduledExecutorService executorService, + Processor onPrepareProcessor, + Processor onExceptionProcessor) { ObjectHelper.notNull(camelContext, "CamelContext", this); ObjectHelper.notNull(redeliveryPolicy, "RedeliveryPolicy", this); diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/WeightedLoadBalancer.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/WeightedLoadBalancer.java index 84037f146a75..581abfcd9e9a 100644 --- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/WeightedLoadBalancer.java +++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/WeightedLoadBalancer.java @@ -25,7 +25,7 @@ public abstract class WeightedLoadBalancer extends QueueLoadBalancer { transient int lastIndex = -1; - public WeightedLoadBalancer(List<Integer> distributionRatios) { + protected WeightedLoadBalancer(List<Integer> distributionRatios) { this.ratios = distributionRatios.stream() .map(DistributionRatio::new) .toList(); diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java index b76050b47b5a..a6ec4ec9d2ce 100644 --- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java +++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java @@ -43,8 +43,8 @@ public abstract class SagaProcessor extends BaseDelegateProcessorSupport impleme private String id; private String routeId; - public SagaProcessor(CamelContext camelContext, Processor childProcessor, CamelSagaService sagaService, - SagaCompletionMode completionMode, CamelSagaStep step) { + protected SagaProcessor(CamelContext camelContext, Processor childProcessor, CamelSagaService sagaService, + SagaCompletionMode completionMode, CamelSagaStep step) { super(ObjectHelper.notNull(childProcessor, "childProcessor")); this.sagaService = ObjectHelper.notNull(sagaService, "sagaService"); this.completionMode = ObjectHelper.notNull(completionMode, "completionMode");
