You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by cm...@apache.org on 2011/06/26 22:53:06 UTC
svn commit: r1139939 -
/camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Producer.java
Author: cmueller
Date: Sun Jun 26 20:53:05 2011
New Revision: 1139939
URL: http://svn.apache.org/viewvc?rev=1139939&view=rev
Log:
CAMEL-4126: S3Producer does not use CamelAwsS3ContentLength or CamelAwsS3ContentType
Modified:
camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Producer.java
Modified: camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Producer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Producer.java?rev=1139939&r1=1139938&r2=1139939&view=diff
==============================================================================
--- camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Producer.java (original)
+++ camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Producer.java Sun Jun 26 20:53:05 2011
@@ -45,6 +45,16 @@ public class S3Producer extends DefaultP
public void process(Exchange exchange) throws Exception {
ObjectMetadata objectMetadata = new ObjectMetadata();
+ Long contentLength = exchange.getIn().getHeader(S3Constants.CONTENT_LENGTH, Long.class);
+ if (contentLength != null) {
+ objectMetadata.setContentLength(contentLength);
+ }
+
+ String contentType = exchange.getIn().getHeader(S3Constants.CONTENT_TYPE, String.class);
+ if (contentType != null) {
+ objectMetadata.setContentType(contentType);
+ }
+
PutObjectRequest putObjectRequest = new PutObjectRequest(
getConfiguration().getBucketName(),
determineKey(exchange),