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 2020/11/03 09:42:28 UTC
[camel] 01/03: camel-core - Optimize to only one camel context
reference in channel
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 <cl...@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