Support Subject as header into sns fifo sink

apache · Sep 14, 2021 · 6deed50 · 6deed50
1 parent a6adb92
commit 6deed50
Showing 1 changed file with 18 additions and 1 deletion.
diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-sns-fifo-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-sns-fifo-sink.kamelet.yaml
@@ -13,7 +13,12 @@ metadata:
 spec:
   definition:
     title: AWS SNS FIFO Sink
-    description: Send message to an AWS SNS FIFO Topic
+    description: |- 
+      Send message to an AWS SNS FIFO Topic
+
+      The Kamelet expects the following headers to be set:
+
+      - `subject` / `ce-subject`: the subject of the message
     required:
       - topicNameOrArn
       - accessKey
@@ -66,6 +71,18 @@ spec:
     from:
       uri: kamelet:source
       steps:
+      - choice:
+          when:
+          - simple: "${header[subject]}"
+            steps:
+            - set-header:
+                name: CamelAwsSnsSubject
+                simple: "${header[subject]}"
+          - simple: "${header[ce-subject]}"
+            steps:
+            - set-header:
+                name: CamelAwsSnsSubject
+                simple: "${header[ce-subject]}"
       - set-property:
           name: contentBasedDeduplication
           constant: "{{contentBasedDeduplication}}"