This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push: new 13f2df2568e Polished 13f2df2568e is described below commit 13f2df2568ec6f7632ff85887c5580eb72d8b2a4 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Mon Dec 12 11:46:26 2022 +0100 Polished --- .../main/java/org/apache/camel/builder/BuilderSupport.java | 2 +- .../src/main/java/org/apache/camel/processor/Pipeline.java | 12 +----------- 2 files changed, 2 insertions(+), 12 deletions(-) diff --git a/core/camel-core-model/src/main/java/org/apache/camel/builder/BuilderSupport.java b/core/camel-core-model/src/main/java/org/apache/camel/builder/BuilderSupport.java index 9c0c99dbd8d..4e3270a06cc 100644 --- a/core/camel-core-model/src/main/java/org/apache/camel/builder/BuilderSupport.java +++ b/core/camel-core-model/src/main/java/org/apache/camel/builder/BuilderSupport.java @@ -573,7 +573,7 @@ public abstract class BuilderSupport implements CamelContextAware { /** * - * @return true if it an error handler factory was initialized + * @return true if an error handler factory was initialized */ public boolean hasErrorHandlerFactory() { return this.errorHandlerFactory != null; diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java index 48ac38e1ec5..68c8e8d8f36 100644 --- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java +++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java @@ -107,7 +107,7 @@ public class Pipeline extends AsyncProcessorSupport implements Navigate<Processo ExchangeHelper.copyResults(exchange, exchange); // logging nextExchange as it contains the exchange that might have altered the payload and since - // we are logging the completion if will be confusing if we log the original instead + // we are logging the completion it will be confusing if we log the original instead // we could also consider logging the original and the nextExchange then we have *before* and *after* snapshots if (LOG.isTraceEnabled()) { LOG.trace("Processing complete for exchangeId: {} >>> {}", exchange.getExchangeId(), exchange); @@ -127,16 +127,6 @@ public class Pipeline extends AsyncProcessorSupport implements Navigate<Processo this.size = processors.size(); } - private Pipeline(Logger log) { - // used for eager loading - camelContext = null; - reactiveExecutor = null; - processors = null; - size = 0; - PipelineTask task = new PipelineTask(); - log.trace("Loaded {}", task.getClass().getSimpleName()); - } - public static Processor newInstance(CamelContext camelContext, List<Processor> processors) { if (processors.isEmpty()) { return null;