This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch CAMEL-20129 in repository https://gitbox.apache.org/repos/asf/camel.git
commit 061c615d495633bf4c738cbff340c2b68fcd912e Author: Andrea Cosentino <[email protected]> AuthorDate: Mon Nov 20 10:08:03 2023 +0100 Regen Signed-off-by: Andrea Cosentino <[email protected]> --- .../aws2/sqs/transform/AWS2SQSCloudEventDataTypeTransformer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/transform/AWS2SQSCloudEventDataTypeTransformer.java b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/transform/AWS2SQSCloudEventDataTypeTransformer.java index 3851cd94397..65a0afc328e 100644 --- a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/transform/AWS2SQSCloudEventDataTypeTransformer.java +++ b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/transform/AWS2SQSCloudEventDataTypeTransformer.java @@ -44,7 +44,8 @@ public class AWS2SQSCloudEventDataTypeTransformer extends Transformer { headers.put(CloudEvents.CAMEL_CLOUD_EVENT_TYPE, "org.apache.camel.event.aws.sqs.receiveMessage"); if (message.getHeaders().containsKey(Sqs2Constants.RECEIPT_HANDLE)) { - headers.put(CloudEvents.CAMEL_CLOUD_EVENT_SOURCE, "aws.sqs.queue." + message.getHeader(Sqs2Constants.RECEIPT_HANDLE, String.class)); + headers.put(CloudEvents.CAMEL_CLOUD_EVENT_SOURCE, + "aws.sqs.queue." + message.getHeader(Sqs2Constants.RECEIPT_HANDLE, String.class)); } headers.put(CloudEvents.CAMEL_CLOUD_EVENT_SUBJECT, message.getHeader(Sqs2Constants.MESSAGE_ID, String.class));
