(camel) branch main updated: Fixed DDB Stream transform prefix for event source (#13628)

[acosentino]

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));