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 2019/12/07 18:49:49 UTC
[camel] branch camel-3.0.x updated: CAMEL-14263: camel-kubernetes
should use source code generated configurer to avoid reflection
configuration.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.0.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.0.x by this push:
new 99718e6 CAMEL-14263: camel-kubernetes should use source code generated configurer to avoid reflection configuration.
99718e6 is described below
commit 99718e62e39e82b18f060cd720d9f59cbaba48d2
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sat Dec 7 19:49:06 2019 +0100
CAMEL-14263: camel-kubernetes should use source code generated configurer to avoid reflection configuration.
---
.../camel/component/kubernetes/AbstractKubernetesComponent.java | 5 +++--
.../kubernetes/config_maps/KubernetesConfigMapsEndpoint.java | 5 ++++-
.../kubernetes/deployments/KubernetesDeploymentsEndpoint.java | 4 +++-
.../apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java | 5 ++++-
.../kubernetes/namespaces/KubernetesNamespacesEndpoint.java | 5 ++++-
.../camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java | 5 ++++-
.../camel/component/kubernetes/pods/KubernetesPodsEndpoint.java | 5 ++++-
.../KubernetesReplicationControllersEndpoint.java | 4 +++-
.../component/kubernetes/services/KubernetesServicesEndpoint.java | 5 ++++-
9 files changed, 33 insertions(+), 10 deletions(-)
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesComponent.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesComponent.java
index e21ce0a..9abc0f0 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesComponent.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesComponent.java
@@ -27,12 +27,13 @@ public abstract class AbstractKubernetesComponent extends DefaultComponent {
@Override
protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
KubernetesConfiguration config = new KubernetesConfiguration();
- setProperties(config, parameters);
config.setMasterUrl(remaining);
if (ObjectHelper.isEmpty(config.getMasterUrl())) {
throw new IllegalArgumentException("Master URL must be specified");
}
- return doCreateEndpoint(uri, remaining, config);
+ Endpoint endpoint = doCreateEndpoint(uri, remaining, config);
+ setProperties(endpoint, parameters);
+ return endpoint;
}
protected abstract AbstractKubernetesEndpoint doCreateEndpoint(String uri, String remaining, KubernetesConfiguration config) throws Exception;
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java
index 27e8533..d65ee50 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java
@@ -41,7 +41,10 @@ public class KubernetesConfigMapsEndpoint extends AbstractKubernetesEndpoint {
@Override
public Consumer createConsumer(Processor processor) throws Exception {
- return new KubernetesConfigMapsConsumer(this, processor);
+ Consumer consumer = new KubernetesConfigMapsConsumer(this, processor);
+ configureConsumer(consumer);
+ return consumer;
+
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java
index f2c8b20..68e4725 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java
@@ -41,7 +41,9 @@ public class KubernetesDeploymentsEndpoint extends AbstractKubernetesEndpoint {
@Override
public Consumer createConsumer(Processor processor) throws Exception {
- return new KubernetesDeploymentsConsumer(this, processor);
+ Consumer consumer = new KubernetesDeploymentsConsumer(this, processor);
+ configureConsumer(consumer);
+ return consumer;
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java
index 334dd82..32368d3 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java
@@ -41,7 +41,10 @@ public class KubernetesHPAEndpoint extends AbstractKubernetesEndpoint {
@Override
public Consumer createConsumer(Processor processor) throws Exception {
- return new KubernetesHPAConsumer(this, processor);
+ Consumer consumer = new KubernetesHPAConsumer(this, processor);
+ configureConsumer(consumer);
+ return consumer;
+
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java
index 2d996338..162cb1a 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java
@@ -41,7 +41,10 @@ public class KubernetesNamespacesEndpoint extends AbstractKubernetesEndpoint {
@Override
public Consumer createConsumer(Processor processor) throws Exception {
- return new KubernetesNamespacesConsumer(this, processor);
+ Consumer consumer = new KubernetesNamespacesConsumer(this, processor);
+ configureConsumer(consumer);
+ return consumer;
+
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java
index 4d04c12..c4a5da4 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java
@@ -41,7 +41,10 @@ public class KubernetesNodesEndpoint extends AbstractKubernetesEndpoint {
@Override
public Consumer createConsumer(Processor processor) throws Exception {
- return new KubernetesNodesConsumer(this, processor);
+ Consumer consumer = new KubernetesNodesConsumer(this, processor);
+ configureConsumer(consumer);
+ return consumer;
+
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java
index e6850b4..4ee6408 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java
@@ -41,7 +41,10 @@ public class KubernetesPodsEndpoint extends AbstractKubernetesEndpoint {
@Override
public Consumer createConsumer(Processor processor) throws Exception {
- return new KubernetesPodsConsumer(this, processor);
+ Consumer consumer = new KubernetesPodsConsumer(this, processor);
+ configureConsumer(consumer);
+ return consumer;
+
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java
index f394214..a4e6b25 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java
@@ -42,7 +42,9 @@ public class KubernetesReplicationControllersEndpoint extends AbstractKubernetes
@Override
public Consumer createConsumer(Processor processor) throws Exception {
- return new KubernetesReplicationControllersConsumer(this, processor);
+ Consumer consumer = new KubernetesReplicationControllersConsumer(this, processor);
+ configureConsumer(consumer);
+ return consumer;
}
}
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java
index 5fb64dc..f51d4a6 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java
@@ -41,7 +41,10 @@ public class KubernetesServicesEndpoint extends AbstractKubernetesEndpoint {
@Override
public Consumer createConsumer(Processor processor) throws Exception {
- return new KubernetesServicesConsumer(this, processor);
+ Consumer consumer = new KubernetesServicesConsumer(this, processor);
+ configureConsumer(consumer);
+ return consumer;
+
}
}