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
The following commit(s) were added to refs/heads/main by this push:
new 043fd9a (chores) camel-kubernetes: avoid using generic exceptions and
remove unused ones (#5928)
043fd9a is described below
commit 043fd9a54f36f2b2cd3c80e5171e8a3d55aba6b8
Author: Otavio Rodolfo Piske <orpi...@users.noreply.github.com>
AuthorDate: Wed Aug 4 23:01:45 2021 +0200
(chores) camel-kubernetes: avoid using generic exceptions and remove unused
ones (#5928)
---
.../kubernetes/cloud/KubernetesDnsSrvServiceDiscovery.java | 3 ++-
.../cluster/lock/KubernetesLeadershipController.java | 3 ++-
.../kubernetes/config_maps/KubernetesConfigMapsProducer.java | 6 +++---
.../customresources/KubernetesCustomResourcesProducer.java | 10 ++++------
.../kubernetes/deployments/KubernetesDeploymentsProducer.java | 6 +++---
.../camel/component/kubernetes/hpa/KubernetesHPAProducer.java | 6 +++---
.../camel/component/kubernetes/job/KubernetesJobProducer.java | 6 +++---
.../component/kubernetes/nodes/KubernetesNodesProducer.java | 8 ++++----
.../KubernetesPersistentVolumesProducer.java | 2 +-
.../KubernetesPersistentVolumesClaimsProducer.java | 6 +++---
.../component/kubernetes/pods/KubernetesPodsProducer.java | 6 +++---
.../KubernetesReplicationControllersProducer.java | 8 ++++----
.../resources_quota/KubernetesResourcesQuotaProducer.java | 6 +++---
.../kubernetes/secrets/KubernetesSecretsProducer.java | 6 +++---
.../service_accounts/KubernetesServiceAccountsProducer.java | 6 +++---
.../kubernetes/services/KubernetesServicesProducer.java | 6 +++---
.../openshift/build_configs/OpenshiftBuildConfigsProducer.java | 2 +-
.../component/openshift/builds/OpenshiftBuildsProducer.java | 2 +-
18 files changed, 49 insertions(+), 49 deletions(-)
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsSrvServiceDiscovery.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsSrvServiceDiscovery.java
index cf9f8db..c372754 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsSrvServiceDiscovery.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cloud/KubernetesDnsSrvServiceDiscovery.java
@@ -27,6 +27,7 @@ import javax.naming.NamingEnumeration;
import javax.naming.directory.DirContext;
import javax.naming.directory.InitialDirContext;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.cloud.ServiceDefinition;
import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.impl.cloud.DefaultServiceDefinition;
@@ -122,7 +123,7 @@ public class KubernetesDnsSrvServiceDiscovery extends
KubernetesServiceDiscovery
LOGGER.warn("Could not find any service for name={},
query={}", name, query);
}
} catch (Exception e) {
- throw new RuntimeException("Could not resolve services via
DNSSRV", e);
+ throw new RuntimeCamelException("Could not resolve services via
DNSSRV", e);
}
return Collections.emptyList();
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLeadershipController.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLeadershipController.java
index 5252e91..5f4d58d 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLeadershipController.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/cluster/lock/KubernetesLeadershipController.java
@@ -30,6 +30,7 @@ import io.fabric8.kubernetes.api.model.HasMetadata;
import io.fabric8.kubernetes.api.model.Pod;
import io.fabric8.kubernetes.client.KubernetesClient;
import org.apache.camel.CamelContext;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.Service;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -140,7 +141,7 @@ public class KubernetesLeadershipController implements
Service {
refreshStatusLeadershipLost();
break;
default:
- throw new RuntimeException("Unsupported state " +
currentState);
+ throw new RuntimeCamelException("Unsupported state " +
currentState);
}
}
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsProducer.java
index 94f57eb..ceb734c 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsProducer.java
@@ -99,7 +99,7 @@ public class KubernetesConfigMapsProducer extends
DefaultProducer {
exchange.getOut().setBody(configMapsList.getItems());
}
- protected void doGetConfigMap(Exchange exchange) throws Exception {
+ protected void doGetConfigMap(Exchange exchange) {
ConfigMap configMap = null;
String cfMapName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_CONFIGMAP_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -117,7 +117,7 @@ public class KubernetesConfigMapsProducer extends
DefaultProducer {
exchange.getOut().setBody(configMap);
}
- protected void doCreateConfigMap(Exchange exchange) throws Exception {
+ protected void doCreateConfigMap(Exchange exchange) {
ConfigMap configMap = null;
String cfMapName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_CONFIGMAP_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -144,7 +144,7 @@ public class KubernetesConfigMapsProducer extends
DefaultProducer {
exchange.getOut().setBody(configMap);
}
- protected void doDeleteConfigMap(Exchange exchange) throws Exception {
+ protected void doDeleteConfigMap(Exchange exchange) {
String configMapName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_CONFIGMAP_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
if (ObjectHelper.isEmpty(configMapName)) {
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/customresources/KubernetesCustomResourcesProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/customresources/KubernetesCustomResourcesProducer.java
index c234de8..423be07 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/customresources/KubernetesCustomResourcesProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/customresources/KubernetesCustomResourcesProducer.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.kubernetes.customresources;
+import java.io.IOException;
import java.util.Map;
import io.fabric8.kubernetes.client.KubernetesClientException;
@@ -121,8 +122,7 @@ public class KubernetesCustomResourcesProducer extends
DefaultProducer {
exchange.getOut().setBody(customResourcesListItems);
}
- protected void doGet(Exchange exchange, String namespaceName)
- throws Exception {
+ protected void doGet(Exchange exchange, String namespaceName) {
String customResourceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_CRD_INSTANCE_NAME,
String.class);
if (ObjectHelper.isEmpty(customResourceName)) {
throw new IllegalArgumentException("Get a specific Deployment
require specify a Deployment name");
@@ -144,8 +144,7 @@ public class KubernetesCustomResourcesProducer extends
DefaultProducer {
exchange.getOut().setBody(customResourceJSON);
}
- protected void doDelete(Exchange exchange, String namespaceName)
- throws Exception {
+ protected void doDelete(Exchange exchange, String namespaceName) throws
IOException {
String customResourceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_CRD_INSTANCE_NAME,
String.class);
if (ObjectHelper.isEmpty(customResourceName)) {
LOG.error("Delete a specific deployment require specify a
deployment name");
@@ -166,8 +165,7 @@ public class KubernetesCustomResourcesProducer extends
DefaultProducer {
}
}
- protected void doCreate(Exchange exchange, String namespaceName)
- throws Exception {
+ protected void doCreate(Exchange exchange, String namespaceName) throws
IOException {
String customResourceInstance =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_CRD_INSTANCE,
String.class);
JsonObject gitHubSourceJSON = new JsonObject();
try {
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java
index 4f5eb468c..db8fa46 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsProducer.java
@@ -104,7 +104,7 @@ public class KubernetesDeploymentsProducer extends
DefaultProducer {
exchange.getOut().setBody(deploymentList.getItems());
}
- protected void doGetDeployment(Exchange exchange) throws Exception {
+ protected void doGetDeployment(Exchange exchange) {
Deployment deployment = null;
String deploymentName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_DEPLOYMENT_NAME,
String.class);
if (ObjectHelper.isEmpty(deploymentName)) {
@@ -136,7 +136,7 @@ public class KubernetesDeploymentsProducer extends
DefaultProducer {
exchange.getOut().setBody(deployment);
}
- protected void doCreateDeployment(Exchange exchange) throws Exception {
+ protected void doCreateDeployment(Exchange exchange) {
Deployment deployment = null;
String deploymentName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_DEPLOYMENT_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -164,7 +164,7 @@ public class KubernetesDeploymentsProducer extends
DefaultProducer {
exchange.getOut().setBody(deployment);
}
- protected void doScaleDeployment(Exchange exchange) throws Exception {
+ protected void doScaleDeployment(Exchange exchange) {
String deploymentName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_DEPLOYMENT_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
Integer replicasNumber =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_DEPLOYMENT_REPLICAS,
Integer.class);
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAProducer.java
index 738c6c2..a670583 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAProducer.java
@@ -106,7 +106,7 @@ public class KubernetesHPAProducer extends DefaultProducer {
exchange.getOut().setBody(hpaList.getItems());
}
- protected void doGetHPA(Exchange exchange) throws Exception {
+ protected void doGetHPA(Exchange exchange) {
HorizontalPodAutoscaler hpa = null;
String podName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_HPA_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -125,7 +125,7 @@ public class KubernetesHPAProducer extends DefaultProducer {
exchange.getOut().setBody(hpa);
}
- protected void doCreateHPA(Exchange exchange) throws Exception {
+ protected void doCreateHPA(Exchange exchange) {
HorizontalPodAutoscaler hpa = null;
String hpaName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_HPA_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -153,7 +153,7 @@ public class KubernetesHPAProducer extends DefaultProducer {
exchange.getOut().setBody(hpa);
}
- protected void doDeleteHPA(Exchange exchange) throws Exception {
+ protected void doDeleteHPA(Exchange exchange) {
String hpaName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_HPA_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
if (ObjectHelper.isEmpty(hpaName)) {
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobProducer.java
index 1eaa038..6e52816 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobProducer.java
@@ -108,7 +108,7 @@ public class KubernetesJobProducer extends DefaultProducer {
exchange.getOut().setBody(jobList.getItems());
}
- protected void doGetJob(Exchange exchange) throws Exception {
+ protected void doGetJob(Exchange exchange) {
Job job = null;
String jobName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_JOB_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -126,7 +126,7 @@ public class KubernetesJobProducer extends DefaultProducer {
exchange.getOut().setBody(job);
}
- protected void doCreateJob(Exchange exchange) throws Exception {
+ protected void doCreateJob(Exchange exchange) {
Job job = null;
String jobName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_JOB_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -152,7 +152,7 @@ public class KubernetesJobProducer extends DefaultProducer {
exchange.getOut().setBody(job);
}
- protected void doDeleteJob(Exchange exchange) throws Exception {
+ protected void doDeleteJob(Exchange exchange) {
String jobName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_JOB_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
if (ObjectHelper.isEmpty(jobName)) {
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java
index 2cbe37d..f37c3e1 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java
@@ -79,7 +79,7 @@ public class KubernetesNodesProducer extends DefaultProducer {
}
}
- protected void doList(Exchange exchange) throws Exception {
+ protected void doList(Exchange exchange) {
NodeList nodeList = getEndpoint().getKubernetesClient().nodes().list();
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
@@ -99,7 +99,7 @@ public class KubernetesNodesProducer extends DefaultProducer {
exchange.getOut().setBody(nodeList.getItems());
}
- protected void doGetNode(Exchange exchange) throws Exception {
+ protected void doGetNode(Exchange exchange) {
Node node = null;
String pvName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NODE_NAME,
String.class);
if (ObjectHelper.isEmpty(pvName)) {
@@ -112,7 +112,7 @@ public class KubernetesNodesProducer extends
DefaultProducer {
exchange.getOut().setBody(node);
}
- protected void doCreateNode(Exchange exchange) throws Exception {
+ protected void doCreateNode(Exchange exchange) {
Node node = null;
String nodeName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NODE_NAME,
String.class);
NodeSpec nodeSpec =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NODE_SPEC,
NodeSpec.class);
@@ -133,7 +133,7 @@ public class KubernetesNodesProducer extends
DefaultProducer {
exchange.getOut().setBody(node);
}
- protected void doDeleteNode(Exchange exchange) throws Exception {
+ protected void doDeleteNode(Exchange exchange) {
String nodeName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NODE_NAME,
String.class);
if (ObjectHelper.isEmpty(nodeName)) {
LOG.error("Deleting a specific Node require specify a Node name");
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesProducer.java
index 2e967d7..cd518d9 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesProducer.java
@@ -91,7 +91,7 @@ public class KubernetesPersistentVolumesProducer extends
DefaultProducer {
exchange.getOut().setBody(pvList.getItems());
}
- protected void doGetPersistentVolume(Exchange exchange, String operation)
throws Exception {
+ protected void doGetPersistentVolume(Exchange exchange, String operation) {
PersistentVolume pv = null;
String pvName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_NAME,
String.class);
if (ObjectHelper.isEmpty(pvName)) {
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsProducer.java
index d20b400..373ef45 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsProducer.java
@@ -114,7 +114,7 @@ public class KubernetesPersistentVolumesClaimsProducer
extends DefaultProducer {
exchange.getOut().setBody(pvcList.getItems());
}
- protected void doGetPersistentVolumeClaim(Exchange exchange) throws
Exception {
+ protected void doGetPersistentVolumeClaim(Exchange exchange) {
PersistentVolumeClaim pvc = null;
String pvcName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_CLAIM_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -133,7 +133,7 @@ public class KubernetesPersistentVolumesClaimsProducer
extends DefaultProducer {
exchange.getOut().setBody(pvc);
}
- protected void doCreatePersistentVolumeClaim(Exchange exchange) throws
Exception {
+ protected void doCreatePersistentVolumeClaim(Exchange exchange) {
PersistentVolumeClaim pvc = null;
String pvcName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_CLAIM_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -163,7 +163,7 @@ public class KubernetesPersistentVolumesClaimsProducer
extends DefaultProducer {
exchange.getOut().setBody(pvc);
}
- protected void doDeletePersistentVolumeClaim(Exchange exchange) throws
Exception {
+ protected void doDeletePersistentVolumeClaim(Exchange exchange) {
String pvcName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_PERSISTENT_VOLUME_CLAIM_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
if (ObjectHelper.isEmpty(pvcName)) {
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsProducer.java
index f2eb11b..eeb5c9e 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsProducer.java
@@ -107,7 +107,7 @@ public class KubernetesPodsProducer extends DefaultProducer
{
exchange.getOut().setBody(podList.getItems());
}
- protected void doGetPod(Exchange exchange) throws Exception {
+ protected void doGetPod(Exchange exchange) {
Pod pod = null;
String podName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_POD_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -125,7 +125,7 @@ public class KubernetesPodsProducer extends DefaultProducer
{
exchange.getOut().setBody(pod);
}
- protected void doCreatePod(Exchange exchange) throws Exception {
+ protected void doCreatePod(Exchange exchange) {
Pod pod = null;
String podName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_POD_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -151,7 +151,7 @@ public class KubernetesPodsProducer extends DefaultProducer
{
exchange.getOut().setBody(pod);
}
- protected void doDeletePod(Exchange exchange) throws Exception {
+ protected void doDeletePod(Exchange exchange) {
String podName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_POD_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
if (ObjectHelper.isEmpty(podName)) {
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersProducer.java
index ce899af..4e84092 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersProducer.java
@@ -126,7 +126,7 @@ public class KubernetesReplicationControllersProducer
extends DefaultProducer {
}
- protected void doGetReplicationController(Exchange exchange, String
operation) throws Exception {
+ protected void doGetReplicationController(Exchange exchange, String
operation) {
ReplicationController rc = null;
String rcName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -145,7 +145,7 @@ public class KubernetesReplicationControllersProducer
extends DefaultProducer {
exchange.getOut().setBody(rc);
}
- protected void doCreateReplicationController(Exchange exchange, String
operation) throws Exception {
+ protected void doCreateReplicationController(Exchange exchange, String
operation) {
ReplicationController rc = null;
String rcName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -175,7 +175,7 @@ public class KubernetesReplicationControllersProducer
extends DefaultProducer {
exchange.getOut().setBody(rc);
}
- protected void doDeleteReplicationController(Exchange exchange, String
operation) throws Exception {
+ protected void doDeleteReplicationController(Exchange exchange, String
operation) {
String rcName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
if (ObjectHelper.isEmpty(rcName)) {
@@ -194,7 +194,7 @@ public class KubernetesReplicationControllersProducer
extends DefaultProducer {
exchange.getOut().setBody(rcDeleted);
}
- protected void doScaleReplicationController(Exchange exchange, String
operation) throws Exception {
+ protected void doScaleReplicationController(Exchange exchange, String
operation) {
String rcName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
Integer replicasNumber
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaProducer.java
index 45f7226..c32f308 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaProducer.java
@@ -112,7 +112,7 @@ public class KubernetesResourcesQuotaProducer extends
DefaultProducer {
exchange.getOut().setBody(resList.getItems());
}
- protected void doGetResourceQuota(Exchange exchange) throws Exception {
+ protected void doGetResourceQuota(Exchange exchange) {
ResourceQuota rq = null;
String rqName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -130,7 +130,7 @@ public class KubernetesResourcesQuotaProducer extends
DefaultProducer {
exchange.getOut().setBody(rq);
}
- protected void doCreateResourceQuota(Exchange exchange) throws Exception {
+ protected void doCreateResourceQuota(Exchange exchange) {
ResourceQuota rq = null;
String rqName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -158,7 +158,7 @@ public class KubernetesResourcesQuotaProducer extends
DefaultProducer {
exchange.getOut().setBody(rq);
}
- protected void doDeleteResourceQuota(Exchange exchange) throws Exception {
+ protected void doDeleteResourceQuota(Exchange exchange) {
String rqName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_RESOURCES_QUOTA_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
if (ObjectHelper.isEmpty(rqName)) {
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsProducer.java
index 9665597..d520430 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsProducer.java
@@ -108,7 +108,7 @@ public class KubernetesSecretsProducer extends
DefaultProducer {
exchange.getOut().setBody(secretsList.getItems());
}
- protected void doGetSecret(Exchange exchange) throws Exception {
+ protected void doGetSecret(Exchange exchange) {
Secret secret = null;
String secretName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SECRET_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -126,7 +126,7 @@ public class KubernetesSecretsProducer extends
DefaultProducer {
exchange.getOut().setBody(secret);
}
- protected void doCreateSecret(Exchange exchange) throws Exception {
+ protected void doCreateSecret(Exchange exchange) {
Secret secret = null;
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
Secret secretToCreate =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SECRET, Secret.class);
@@ -144,7 +144,7 @@ public class KubernetesSecretsProducer extends
DefaultProducer {
exchange.getOut().setBody(secret);
}
- protected void doDeleteSecret(Exchange exchange) throws Exception {
+ protected void doDeleteSecret(Exchange exchange) {
String secretName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SECRET_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
if (ObjectHelper.isEmpty(secretName)) {
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsProducer.java
index 5bba97c..fd0677e 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsProducer.java
@@ -109,7 +109,7 @@ public class KubernetesServiceAccountsProducer extends
DefaultProducer {
exchange.getOut().setBody(saList.getItems());
}
- protected void doGetServiceAccount(Exchange exchange) throws Exception {
+ protected void doGetServiceAccount(Exchange exchange) {
ServiceAccount sa = null;
String saName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_ACCOUNT_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -127,7 +127,7 @@ public class KubernetesServiceAccountsProducer extends
DefaultProducer {
exchange.getOut().setBody(sa);
}
- protected void doCreateServiceAccount(Exchange exchange) throws Exception {
+ protected void doCreateServiceAccount(Exchange exchange) {
ServiceAccount sa = null;
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
ServiceAccount saToCreate
@@ -146,7 +146,7 @@ public class KubernetesServiceAccountsProducer extends
DefaultProducer {
exchange.getOut().setBody(sa);
}
- protected void doDeleteServiceAccount(Exchange exchange) throws Exception {
+ protected void doDeleteServiceAccount(Exchange exchange) {
String saName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_ACCOUNT_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
if (ObjectHelper.isEmpty(saName)) {
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java
index 3f9ba9f..19b77fb 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesProducer.java
@@ -115,7 +115,7 @@ public class KubernetesServicesProducer extends
DefaultProducer {
exchange.getOut().setBody(servicesList.getItems());
}
- protected void doGetService(Exchange exchange) throws Exception {
+ protected void doGetService(Exchange exchange) {
Service service = null;
String serviceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -132,7 +132,7 @@ public class KubernetesServicesProducer extends
DefaultProducer {
exchange.getOut().setBody(service);
}
- protected void doCreateService(Exchange exchange) throws Exception {
+ protected void doCreateService(Exchange exchange) {
Service service = null;
String serviceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
@@ -157,7 +157,7 @@ public class KubernetesServicesProducer extends
DefaultProducer {
exchange.getOut().setBody(service);
}
- protected void doDeleteService(Exchange exchange) throws Exception {
+ protected void doDeleteService(Exchange exchange) {
String serviceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_SERVICE_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
if (ObjectHelper.isEmpty(serviceName)) {
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsProducer.java
index b9326af..f848bd9 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsProducer.java
@@ -102,7 +102,7 @@ public class OpenshiftBuildConfigsProducer extends
DefaultProducer {
exchange.getOut().setBody(buildConfigsList.getItems());
}
- protected void doGetBuildConfig(Exchange exchange) throws Exception {
+ protected void doGetBuildConfig(Exchange exchange) {
BuildConfig buildConfig = null;
String buildConfigName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_BUILD_CONFIG_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
diff --git
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsProducer.java
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsProducer.java
index 01451f4..fed7632 100644
---
a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsProducer.java
+++
b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsProducer.java
@@ -101,7 +101,7 @@ public class OpenshiftBuildsProducer extends
DefaultProducer {
exchange.getOut().setBody(buildList.getItems());
}
- protected void doGetBuild(Exchange exchange) throws Exception {
+ protected void doGetBuild(Exchange exchange) {
Build build = null;
String buildName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_BUILD_NAME,
String.class);
String namespaceName =
exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME,
String.class);
