You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2024/03/27 11:19:48 UTC
(camel) branch ddb-transform created (now 1597f04f692)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch ddb-transform
in repository https://gitbox.apache.org/repos/asf/camel.git
at 1597f04f692 Fixed DDB Stream transform prefix for event source
This branch includes the following new commits:
new 1597f04f692 Fixed DDB Stream transform prefix for event source
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(camel) 01/01: Fixed DDB Stream transform prefix for event source
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch ddb-transform
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 1597f04f69243098ed6877109e8ee4365c23898f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Mar 27 11:56:54 2024 +0100
Fixed DDB Stream transform prefix for event source
Signed-off-by: Andrea Cosentino <an...@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));