[camel] branch master updated: CAMEL-12280 - Camel AWS S3: Add other fields in the exchange returned from the consumer

[acosentino]

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 6202bd6  CAMEL-12280 - Camel AWS S3: Add other fields in the exchange 
returned from the consumer
6202bd6 is described below

commit 6202bd67c9093bcc9a5d572d4ef321c1ea90d910
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Feb 20 08:37:06 2018 +0100

    CAMEL-12280 - Camel AWS S3: Add other fields in the exchange returned from 
the consumer
---
 .../src/main/java/org/apache/camel/component/aws/s3/S3Constants.java   | 2 ++
 .../src/main/java/org/apache/camel/component/aws/s3/S3Endpoint.java    | 3 +++
 2 files changed, 5 insertions(+)

diff --git 
a/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Constants.java
 
b/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Constants.java
index ce44574..c687bd0 100644
--- 
a/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Constants.java
+++ 
b/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Constants.java
@@ -44,4 +44,6 @@ public interface S3Constants {
     String S3_HEADERS                      = "CamelAwsS3Headers";
     String S3_OPERATION                    = "CamelAwsS3Operation";
     String SERVER_SIDE_ENCRYPTION          = "CamelAwsS3ServerSideEncryption";
+    String EXPIRATION_TIME                 = "CamelAwsS3ExpirationTime";
+    String REPLICATION_STATUS              = "CamelAwsS3ReplicationStatus";
 }
\ No newline at end of file
diff --git 
a/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Endpoint.java
 
b/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Endpoint.java
index 24dc311..76ce195 100644
--- 
a/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Endpoint.java
+++ 
b/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Endpoint.java
@@ -180,6 +180,9 @@ public class S3Endpoint extends ScheduledPollEndpoint {
         message.setHeader(S3Constants.S3_HEADERS, 
objectMetadata.getRawMetadata());
         message.setHeader(S3Constants.SERVER_SIDE_ENCRYPTION, 
objectMetadata.getSSEAlgorithm());
         message.setHeader(S3Constants.USER_METADATA, 
objectMetadata.getUserMetadata());
+        message.setHeader(S3Constants.EXPIRATION_TIME, 
objectMetadata.getExpirationTime());
+        message.setHeader(S3Constants.REPLICATION_STATUS, 
objectMetadata.getReplicationStatus());
+        message.setHeader(S3Constants.STORAGE_CLASS, 
objectMetadata.getStorageClass());
 
         /**
          * If includeBody != true, it is safe to close the object here. If

-- 
To stop receiving notification emails like this one, please contact
acosent...@apache.org.