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 2020/03/06 17:25:32 UTC
[camel] branch master updated: CAMEL-14664 - Camel-AWS2-S3: add
more integration tests, deleteBucket
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
The following commit(s) were added to refs/heads/master by this push:
new 10b348f CAMEL-14664 - Camel-AWS2-S3: add more integration tests, deleteBucket
10b348f is described below
commit 10b348fd77d1e04650eb7b84d876cd8fe12934cd
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Mar 6 18:24:27 2020 +0100
CAMEL-14664 - Camel-AWS2-S3: add more integration tests, deleteBucket
---
.../java/org/apache/camel/component/aws2/s3/AWS2S3Producer.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Producer.java b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Producer.java
index 7a13e2c..52701d3 100644
--- a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Producer.java
+++ b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Producer.java
@@ -45,6 +45,7 @@ import software.amazon.awssdk.services.s3.model.BucketCannedACL;
import software.amazon.awssdk.services.s3.model.CopyObjectRequest;
import software.amazon.awssdk.services.s3.model.CopyObjectResponse;
import software.amazon.awssdk.services.s3.model.DeleteBucketRequest;
+import software.amazon.awssdk.services.s3.model.DeleteBucketResponse;
import software.amazon.awssdk.services.s3.model.DeleteObjectRequest;
import software.amazon.awssdk.services.s3.model.GetObjectRequest;
import software.amazon.awssdk.services.s3.model.GetObjectResponse;
@@ -233,7 +234,10 @@ public class AWS2S3Producer extends DefaultProducer {
final String bucketName = determineBucketName(exchange);
DeleteBucketRequest.Builder deleteBucketRequest = DeleteBucketRequest.builder().bucket(bucketName);
- s3Client.deleteBucket(deleteBucketRequest.build());
+ DeleteBucketResponse resp = s3Client.deleteBucket(deleteBucketRequest.build());
+
+ Message message = getMessageForResponse(exchange);
+ message.setBody(resp);
}
private void getObject(S3Client s3Client, Exchange exchange) {