You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/01/22 08:30:25 UTC
[camel] 01/04: CAMEL-16068 - Use HeadBucketRequest to check if a
bucket exists or not, thanks fyi for the suggestion
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 <an...@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) {