[camel] 03/04: CAMEL-16068 - Use HeadBucketRequest to check if a bucket exists or not for consumer too, thanks fyi for the suggestion

[acosentino]

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

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 1fa60a51885826d0282bc7e179a5eadd7a5133ca
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Jan 22 09:24:48 2021 +0100

    CAMEL-16068 - Use HeadBucketRequest to check if a bucket exists or not for 
consumer too, thanks fyi for the suggestion
---
 .../java/org/apache/camel/component/aws2/s3/AWS2S3Consumer.java     | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Consumer.java
 
b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Consumer.java
index 40d05ec..5e6e9ba 100644
--- 
a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Consumer.java
+++ 
b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Consumer.java
@@ -46,6 +46,7 @@ import 
software.amazon.awssdk.services.s3.model.DeleteObjectRequest;
 import software.amazon.awssdk.services.s3.model.GetObjectRequest;
 import software.amazon.awssdk.services.s3.model.GetObjectRequest.Builder;
 import software.amazon.awssdk.services.s3.model.GetObjectResponse;
+import software.amazon.awssdk.services.s3.model.HeadBucketRequest;
 import software.amazon.awssdk.services.s3.model.ListObjectsRequest;
 import software.amazon.awssdk.services.s3.model.ListObjectsResponse;
 import software.amazon.awssdk.services.s3.model.S3Object;
@@ -71,10 +72,7 @@ public class AWS2S3Consumer extends 
ScheduledBatchPollingConsumer {
 
         if (getConfiguration().isMoveAfterRead()) {
             try {
-                ListObjectsRequest.Builder builder = 
ListObjectsRequest.builder();
-                builder.bucket(getConfiguration().getDestinationBucket());
-                builder.maxKeys(maxMessagesPerPoll);
-                getAmazonS3Client().listObjects(builder.build());
+                
getAmazonS3Client().headBucket(HeadBucketRequest.builder().bucket(getConfiguration().getDestinationBucket()).build());
                 LOG.trace("Bucket [{}] already exists", 
getConfiguration().getDestinationBucket());
                 return;
             } catch (AwsServiceException ase) {