This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit baba9ef6657ad3d8f5bbb7b99f9d53e6dbbeb223 Author: Christoph Deppisch <[email protected]> AuthorDate: Fri Nov 18 17:28:11 2022 +0100 Preserve AWS S3 Key header as it is required during onCompletion --- .../utils/format/converter/aws2/s3/AWS2S3CloudEventOutputType.java | 2 -- .../utils/format/converter/aws2/s3/AWS2S3CloudEventOutputTypeTest.java | 2 +- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/converter/aws2/s3/AWS2S3CloudEventOutputType.java b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/converter/aws2/s3/AWS2S3CloudEventOutputType.java index 655a4cef..13579054 100644 --- a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/converter/aws2/s3/AWS2S3CloudEventOutputType.java +++ b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/converter/aws2/s3/AWS2S3CloudEventOutputType.java @@ -50,8 +50,6 @@ public class AWS2S3CloudEventOutputType implements DataTypeConverter { if (encoding != null) { headers.put(CloudEvent.CAMEL_CLOUD_EVENT_DATA_CONTENT_ENCODING, encoding); } - - exchange.getMessage().removeHeaders("CamelAwsS3*"); } private String getEventTime(Exchange exchange) { diff --git a/library/camel-kamelets-utils/src/test/java/org/apache/camel/kamelets/utils/format/converter/aws2/s3/AWS2S3CloudEventOutputTypeTest.java b/library/camel-kamelets-utils/src/test/java/org/apache/camel/kamelets/utils/format/converter/aws2/s3/AWS2S3CloudEventOutputTypeTest.java index 10c51708..0a71f90d 100644 --- a/library/camel-kamelets-utils/src/test/java/org/apache/camel/kamelets/utils/format/converter/aws2/s3/AWS2S3CloudEventOutputTypeTest.java +++ b/library/camel-kamelets-utils/src/test/java/org/apache/camel/kamelets/utils/format/converter/aws2/s3/AWS2S3CloudEventOutputTypeTest.java @@ -52,7 +52,7 @@ class AWS2S3CloudEventOutputTypeTest { outputType.convert(exchange); Assertions.assertTrue(exchange.getMessage().hasHeaders()); - Assertions.assertFalse(exchange.getMessage().getHeaders().containsKey(AWS2S3Constants.KEY)); + Assertions.assertTrue(exchange.getMessage().getHeaders().containsKey(AWS2S3Constants.KEY)); assertEquals("kamelet:aws-s3-source", exchange.getMessage().getHeader(CloudEvents.CAMEL_CLOUD_EVENT_TYPE)); assertEquals("test1.txt", exchange.getMessage().getHeader(CloudEvents.CAMEL_CLOUD_EVENT_SUBJECT)); assertEquals("myBucket", exchange.getMessage().getHeader(CloudEvents.CAMEL_CLOUD_EVENT_SOURCE));
