[camel] branch main updated: Camel-AWS2-S3: Improved Health Check with the invocation of an head bucket operation instead of listing bucket

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino 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 bf9041dd027 Camel-AWS2-S3: Improved Health Check with the invocation 
of an head bucket operation instead of listing bucket
bf9041dd027 is described below

commit bf9041dd0271c150b32dc623863cd63900f41f49
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Mon Sep 5 18:01:45 2022 +0200

    Camel-AWS2-S3: Improved Health Check with the invocation of an head bucket 
operation instead of listing bucket
---
 .../camel/component/aws2/s3/AWS2S3ConsumerHealthCheck.java       | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3ConsumerHealthCheck.java
 
b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3ConsumerHealthCheck.java
index 18b4d8d6c67..a68e1bc6276 100644
--- 
a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3ConsumerHealthCheck.java
+++ 
b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3ConsumerHealthCheck.java
@@ -26,6 +26,7 @@ import 
software.amazon.awssdk.core.exception.SdkClientException;
 import software.amazon.awssdk.regions.Region;
 import software.amazon.awssdk.services.s3.S3Client;
 import software.amazon.awssdk.services.s3.S3ClientBuilder;
+import software.amazon.awssdk.services.s3.model.HeadBucketRequest;
 
 public class AWS2S3ConsumerHealthCheck extends AbstractHealthCheck {
 
@@ -54,18 +55,18 @@ public class AWS2S3ConsumerHealthCheck extends 
AbstractHealthCheck {
                 builder.down();
                 return;
             }
+            S3Client client;
             if (!configuration.isUseDefaultCredentialsProvider()) {
                 AwsBasicCredentials cred
                         = 
AwsBasicCredentials.create(configuration.getAccessKey(), 
configuration.getSecretKey());
                 S3ClientBuilder clientBuilder = S3Client.builder();
-                S3Client client = 
clientBuilder.credentialsProvider(StaticCredentialsProvider.create(cred))
+                client = 
clientBuilder.credentialsProvider(StaticCredentialsProvider.create(cred))
                         .region(Region.of(configuration.getRegion())).build();
-                client.listBuckets();
             } else {
                 S3ClientBuilder clientBuilder = S3Client.builder();
-                S3Client client = 
clientBuilder.region(Region.of(configuration.getRegion())).build();
-                client.listBuckets();
+                client = 
clientBuilder.region(Region.of(configuration.getRegion())).build();
             }
+            
client.headBucket(HeadBucketRequest.builder().bucket(configuration.getBucketName()).build());
         } catch (SdkClientException e) {
             builder.message(e.getMessage());
             builder.error(e);