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.git
The following commit(s) were added to refs/heads/main by this push: new ff63db20423 Fixed DDB Stream transform prefix for event source (#13628) ff63db20423 is described below commit ff63db20423162434aaed271109df1ea487d4efb Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Wed Mar 27 12:21:49 2024 +0100 Fixed DDB Stream transform prefix for event source (#13628) Signed-off-by: Andrea Cosentino <anco...@gmail.com> --- .../ddbstream/transform/Ddb2StreamCloudEventDataTypeTransformer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/transform/Ddb2StreamCloudEventDataTypeTransformer.java b/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/transform/Ddb2StreamCloudEventDataTypeTransformer.java index 4952822e0f8..8960169079c 100644 --- a/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/transform/Ddb2StreamCloudEventDataTypeTransformer.java +++ b/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/transform/Ddb2StreamCloudEventDataTypeTransformer.java @@ -46,7 +46,7 @@ public class Ddb2StreamCloudEventDataTypeTransformer extends Transformer { if (message.getHeaders().containsKey(Ddb2StreamConstants.EVENT_SOURCE)) { headers.put(CloudEvent.CAMEL_CLOUD_EVENT_SOURCE, - "aws.s3.ddbstream." + message.getHeader(Ddb2StreamConstants.EVENT_SOURCE, String.class)); + "aws.ddbstream." + message.getHeader(Ddb2StreamConstants.EVENT_SOURCE, String.class)); } headers.put(CloudEvent.CAMEL_CLOUD_EVENT_SUBJECT, message.getHeader(Ddb2StreamConstants.EVENT_ID, String.class));