This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 880936157c1fc46eeafebc5d539a1194e662b972 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Tue Nov 3 09:39:23 2020 +0100 camel-core - Optimize to only one camel context reference in channel --- .../main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java | 2 +- .../src/main/java/org/apache/camel/impl/engine/DefaultChannel.java | 2 -- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java index b409d9f..ac2014b 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java @@ -98,7 +98,7 @@ public class CamelInternalProcessor extends DelegateAsyncProcessor implements In private static final Object[] EMPTY_STATES = new Object[0]; - private final CamelContext camelContext; + final CamelContext camelContext; private final ReactiveExecutor reactiveExecutor; private final ShutdownStrategy shutdownStrategy; private final List<CamelInternalProcessorAdvice<?>> advices = new ArrayList<>(); diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultChannel.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultChannel.java index 3f1e5c6..776f958 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultChannel.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultChannel.java @@ -64,7 +64,6 @@ public class DefaultChannel extends CamelInternalProcessor implements Channel { private Processor output; private NamedNode definition; private ManagementInterceptStrategy.InstrumentationProcessor<?> instrumentationProcessor; - private CamelContext camelContext; private Route route; public DefaultChannel(CamelContext camelContext) { @@ -164,7 +163,6 @@ public class DefaultChannel extends CamelInternalProcessor implements Channel { throws Exception { this.route = route; this.definition = definition; - this.camelContext = route.getCamelContext(); this.nextProcessor = nextProcessor; // init CamelContextAware as early as possible on nextProcessor