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 f3a1e69 CAMEL-12437 - Ability to define dynamic bucket name for s3 router using standard S3Constants.BUCKET_NAME supplied in header f3a1e69 is described below commit f3a1e69682b5c660ead1a94ac27c958e056cd15c Author: Laptseu <alexlaptseu1@Alexs-MacBook-Pro.local> AuthorDate: Thu Apr 12 22:28:46 2018 +1000 CAMEL-12437 - Ability to define dynamic bucket name for s3 router using standard S3Constants.BUCKET_NAME supplied in header --- .../main/java/org/apache/camel/component/aws/s3/S3Producer.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Producer.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Producer.java index df6e1c3..2efb990 100644 --- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Producer.java +++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Producer.java @@ -228,7 +228,12 @@ public class S3Producer extends DefaultProducer { is = new ByteArrayInputStream(baos.toByteArray()); } - putObjectRequest = new PutObjectRequest(getConfiguration().getBucketName(), determineKey(exchange), is, objectMetadata); + String bucketName = exchange.getIn().getHeader(S3Constants.BUCKET_NAME, String.class); + if (bucketName == null){ + LOG.trace("Bucket name is not in header, using default one [{}]...", getConfiguration().getBucketName()); + bucketName = getConfiguration().getBucketName(); + } + putObjectRequest = new PutObjectRequest(bucketName, determineKey(exchange), is, objectMetadata); String storageClass = determineStorageClass(exchange); if (storageClass != null) { -- To stop receiving notification emails like this one, please contact acosent...@apache.org.