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 14:06:35 UTC
[camel] 02/02: Camel-AWS2-S3: Fixed CS
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 94adfddae0ed486b2977d15d8dde716a940098bf
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Mar 6 15:05:07 2020 +0100
Camel-AWS2-S3: Fixed CS
---
.../apache/camel/component/aws2/s3/AWS2S3Producer.java | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
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 dcbd01d..7a13e2c 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
@@ -121,17 +121,17 @@ public class AWS2S3Producer extends DefaultProducer {
} else {
is = exchange.getIn().getMandatoryBody(InputStream.class);
if (objectMetadata.containsKey(Exchange.CONTENT_LENGTH)) {
- if (objectMetadata.get("Content-Length").equals("0") && ObjectHelper.isEmpty(exchange.getProperty(Exchange.CONTENT_LENGTH))) {
- LOG.debug("The content length is not defined. It needs to be determined by reading the data into memory");
- baos = determineLengthInputStream(is);
- objectMetadata.put("Content-Length", String.valueOf(baos.size()));
- is = new ByteArrayInputStream(baos.toByteArray());
- } else {
- if (ObjectHelper.isNotEmpty(exchange.getProperty(Exchange.CONTENT_LENGTH))) {
- objectMetadata.put("Content-Length", exchange.getProperty(Exchange.CONTENT_LENGTH, String.class));
+ if (objectMetadata.get("Content-Length").equals("0") && ObjectHelper.isEmpty(exchange.getProperty(Exchange.CONTENT_LENGTH))) {
+ LOG.debug("The content length is not defined. It needs to be determined by reading the data into memory");
+ baos = determineLengthInputStream(is);
+ objectMetadata.put("Content-Length", String.valueOf(baos.size()));
+ is = new ByteArrayInputStream(baos.toByteArray());
+ } else {
+ if (ObjectHelper.isNotEmpty(exchange.getProperty(Exchange.CONTENT_LENGTH))) {
+ objectMetadata.put("Content-Length", exchange.getProperty(Exchange.CONTENT_LENGTH, String.class));
+ }
}
}
- }
}
final String bucketName = determineBucketName(exchange);