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 be7e211c772098854e5d1b34c3f474b25ca27f84 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Fri Jan 22 09:16:15 2021 +0100 CAMEL-16068 - Use HeadBucketRequest to check if a bucket exists or not, thanks fyi for the suggestion --- .../java/org/apache/camel/component/aws2/s3/AWS2S3Endpoint.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Endpoint.java b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Endpoint.java index 78f1523..fe7fdba 100644 --- a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Endpoint.java +++ b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Endpoint.java @@ -44,6 +44,8 @@ import software.amazon.awssdk.core.ResponseInputStream; import software.amazon.awssdk.services.s3.S3Client; import software.amazon.awssdk.services.s3.model.CreateBucketRequest; import software.amazon.awssdk.services.s3.model.GetObjectResponse; +import software.amazon.awssdk.services.s3.model.HeadBucketRequest; +import software.amazon.awssdk.services.s3.model.HeadBucketResponse; import software.amazon.awssdk.services.s3.model.ListObjectsRequest; import software.amazon.awssdk.services.s3.model.PutBucketPolicyRequest; import software.amazon.awssdk.utils.IoUtils; @@ -107,11 +109,7 @@ public class AWS2S3Endpoint extends ScheduledPollEndpoint { String prefix = getConfiguration().getPrefix(); try { - ListObjectsRequest.Builder builder = ListObjectsRequest.builder(); - builder.bucket(bucketName); - builder.prefix(prefix); - builder.maxKeys(maxMessagesPerPoll); - s3Client.listObjects(builder.build()); + s3Client.headBucket(HeadBucketRequest.builder().bucket(bucketName).build()); LOG.trace("Bucket [{}] already exists", bucketName); return; } catch (AwsServiceException ase) {