[camel] 01/02: [CAMEL-16108] The S3 metadata is included in the Exchange as a Header

[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

commit f1ead9c70821686b2e501e4856b67b8bbafc7b87
Author: Vilmos Nagy <vilmos.n...@outlook.com>
AuthorDate: Fri Jan 29 13:25:30 2021 +0100

    [CAMEL-16108] The S3 metadata is included in the Exchange as a Header
---
 .../main/java/org/apache/camel/component/aws2/s3/AWS2S3Constants.java    | 1 +
 .../src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Endpoint.java | 1 +
 2 files changed, 2 insertions(+)

diff --git 
a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Constants.java
 
b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Constants.java
index 8c17660..a14d23c 100644
--- 
a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Constants.java
+++ 
b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Constants.java
@@ -44,4 +44,5 @@ public interface AWS2S3Constants {
     String RANGE_START = "CamelAwsS3RangeStart";
     String RANGE_END = "CamelAwsS3RangeEnd";
     String DOWNLOAD_LINK_EXPIRATION_TIME = 
"CamelAwsS3DowloadLinkExpirationTime";
+    String METADATA = "CamelAwsS3Metadata";
 }
diff --git 
a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Endpoint.java
 
b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Endpoint.java
index 8bf4c36..8be1966 100644
--- 
a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Endpoint.java
+++ 
b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Endpoint.java
@@ -188,6 +188,7 @@ public class AWS2S3Endpoint extends ScheduledPollEndpoint {
         message.setHeader(AWS2S3Constants.EXPIRATION_TIME, 
s3Object.response().expiration());
         message.setHeader(AWS2S3Constants.REPLICATION_STATUS, 
s3Object.response().replicationStatus());
         message.setHeader(AWS2S3Constants.STORAGE_CLASS, 
s3Object.response().storageClass());
+        message.setHeader(AWS2S3Constants.METADATA, 
s3Object.response().metadata());
 
         /*
          * If includeBody == true, it is safe to close the object here because 
the S3Object