This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch objectHelper in repository https://gitbox.apache.org/repos/asf/camel.git
commit c6599824ca0535b9526af7a2c392c2f802758b48 Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Jan 28 10:17:03 2026 +0100 Camel-AWS components: Use ObjectHelper for null checks - EKS Signed-off-by: Andrea Cosentino <[email protected]> --- .../camel/component/aws2/eks/EKS2Component.java | 3 ++- .../camel/component/aws2/eks/EKS2Endpoint.java | 4 ++-- .../camel/component/aws2/eks/EKS2Producer.java | 26 +++++++++++----------- 3 files changed, 17 insertions(+), 16 deletions(-) diff --git a/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Component.java b/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Component.java index 1687c2a87b4c..2fcf4d3412cc 100644 --- a/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Component.java +++ b/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Component.java @@ -23,6 +23,7 @@ import org.apache.camel.Endpoint; import org.apache.camel.spi.Metadata; import org.apache.camel.spi.annotations.Component; import org.apache.camel.support.HealthCheckComponent; +import org.apache.camel.util.ObjectHelper; /** * For working with Amazon EKS SDK v2. @@ -43,7 +44,7 @@ public class EKS2Component extends HealthCheckComponent { @Override protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception { - EKS2Configuration configuration = this.configuration != null ? this.configuration.copy() : new EKS2Configuration(); + EKS2Configuration configuration = ObjectHelper.isNotEmpty(this.configuration) ? this.configuration.copy() : new EKS2Configuration(); EKS2Endpoint endpoint = new EKS2Endpoint(uri, this, configuration); setProperties(endpoint, parameters); if (Boolean.FALSE.equals(configuration.isUseDefaultCredentialsProvider()) diff --git a/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Endpoint.java b/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Endpoint.java index 5ca1727beb9d..184c7290f94f 100644 --- a/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Endpoint.java +++ b/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Endpoint.java @@ -66,14 +66,14 @@ public class EKS2Endpoint extends ScheduledPollEndpoint implements EndpointServi public void doStart() throws Exception { super.doStart(); - eksClient = configuration.getEksClient() != null + eksClient = ObjectHelper.isNotEmpty(configuration.getEksClient()) ? configuration.getEksClient() : EKS2ClientFactory.getEksClient(configuration); } @Override public void doStop() throws Exception { if (ObjectHelper.isEmpty(configuration.getEksClient())) { - if (eksClient != null) { + if (ObjectHelper.isNotEmpty(eksClient)) { eksClient.close(); } } diff --git a/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Producer.java b/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Producer.java index d3efc22ec543..14c992a5da74 100644 --- a/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Producer.java +++ b/components/camel-aws/camel-aws2-eks/src/main/java/org/apache/camel/component/aws2/eks/EKS2Producer.java @@ -111,11 +111,11 @@ public class EKS2Producer extends DefaultProducer { () -> { ListClustersRequest.Builder builder = ListClustersRequest.builder(); Integer maxResults = getOptionalHeader(exchange, EKS2Constants.MAX_RESULTS, Integer.class); - if (maxResults != null) { + if (ObjectHelper.isNotEmpty(maxResults)) { builder.maxResults(maxResults); } String nextToken = getOptionalHeader(exchange, EKS2Constants.NEXT_TOKEN, String.class); - if (nextToken != null) { + if (ObjectHelper.isNotEmpty(nextToken)) { builder.nextToken(nextToken); } return eksClient.listClusters(builder.build()); @@ -123,7 +123,7 @@ public class EKS2Producer extends DefaultProducer { "List Clusters", (ListClustersResponse response, Message message) -> { message.setHeader(EKS2Constants.NEXT_TOKEN, response.nextToken()); - message.setHeader(EKS2Constants.IS_TRUNCATED, response.nextToken() != null); + message.setHeader(EKS2Constants.IS_TRUNCATED, ObjectHelper.isNotEmpty(response.nextToken())); }); } @@ -135,22 +135,22 @@ public class EKS2Producer extends DefaultProducer { () -> { CreateClusterRequest.Builder builder = CreateClusterRequest.builder(); String clusterName = getOptionalHeader(exchange, EKS2Constants.CLUSTER_NAME, String.class); - if (clusterName != null) { + if (ObjectHelper.isNotEmpty(clusterName)) { builder.name(clusterName); } String roleArn = getOptionalHeader(exchange, EKS2Constants.ROLE_ARN, String.class); - if (roleArn != null) { + if (ObjectHelper.isNotEmpty(roleArn)) { builder.roleArn(roleArn); } VpcConfigRequest vpcConfig = getOptionalHeader(exchange, EKS2Constants.VPC_CONFIG, VpcConfigRequest.class); - if (vpcConfig != null) { + if (ObjectHelper.isNotEmpty(vpcConfig)) { builder.resourcesVpcConfig(vpcConfig); } return eksClient.createCluster(builder.build()); }, "Create Cluster", (CreateClusterResponse response, Message message) -> { - if (response.cluster() != null) { + if (ObjectHelper.isNotEmpty(response.cluster())) { message.setHeader(EKS2Constants.CLUSTER_ARN, response.cluster().arn()); } }); @@ -168,7 +168,7 @@ public class EKS2Producer extends DefaultProducer { }, "Describe Cluster", (DescribeClusterResponse response, Message message) -> { - if (response.cluster() != null) { + if (ObjectHelper.isNotEmpty(response.cluster())) { message.setHeader(EKS2Constants.CLUSTER_ARN, response.cluster().arn()); } }); @@ -186,7 +186,7 @@ public class EKS2Producer extends DefaultProducer { }, "Delete Cluster", (DeleteClusterResponse response, Message message) -> { - if (response.cluster() != null) { + if (ObjectHelper.isNotEmpty(response.cluster())) { message.setHeader(EKS2Constants.CLUSTER_ARN, response.cluster().arn()); } }); @@ -235,7 +235,7 @@ public class EKS2Producer extends DefaultProducer { throw new IllegalArgumentException( String.format("Expected body of type %s but was %s", requestClass.getName(), - payload != null ? payload.getClass().getName() : "null")); + ObjectHelper.isNotEmpty(payload) ? payload.getClass().getName() : "null")); } } else { try { @@ -247,7 +247,7 @@ public class EKS2Producer extends DefaultProducer { } Message message = getMessageForResponse(exchange); message.setBody(result); - if (responseProcessor != null) { + if (ObjectHelper.isNotEmpty(responseProcessor)) { responseProcessor.accept(result, message); } } @@ -278,7 +278,7 @@ public class EKS2Producer extends DefaultProducer { "producers", WritableHealthCheckRepository.class); - if (healthCheckRepository != null) { + if (ObjectHelper.isNotEmpty(healthCheckRepository)) { String id = getEndpoint().getId(); producerHealthCheck = new EKS2ProducerHealthCheck(getEndpoint(), id); producerHealthCheck.setEnabled(getEndpoint().getComponent().isHealthCheckProducerEnabled()); @@ -288,7 +288,7 @@ public class EKS2Producer extends DefaultProducer { @Override protected void doStop() throws Exception { - if (healthCheckRepository != null && producerHealthCheck != null) { + if (ObjectHelper.isNotEmpty(healthCheckRepository) && ObjectHelper.isNotEmpty(producerHealthCheck)) { healthCheckRepository.removeHealthCheck(producerHealthCheck); producerHealthCheck = null; }
