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 2021/09/14 10:23:08 UTC
[camel-kamelets] branch main updated (1c03770 -> 731de12)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git.
from 1c03770 Support Subject as header into sns sink
new a6adb92 Support Subject as header into sns fifo sink
new 6deed50 Support Subject as header into sns fifo sink
new 731de12 Support Subject as header into sns fifo sink
The 3 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.
Summary of changes:
aws-sns-fifo-sink.kamelet.yaml | 19 ++++++++++++++++++-
docs/modules/ROOT/pages/aws-sns-fifo-sink.adoc | 4 ++++
.../resources/kamelets/aws-sns-fifo-sink.kamelet.yaml | 19 ++++++++++++++++++-
3 files changed, 40 insertions(+), 2 deletions(-)
[camel-kamelets] 03/03: Support Subject as header into sns fifo sink
Posted by ac...@apache.org.
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-kamelets.git
commit 731de12a5c98051c26ba23d96bf282af389a407a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Sep 14 12:19:05 2021 +0200
Support Subject as header into sns fifo sink
---
docs/modules/ROOT/pages/aws-sns-fifo-sink.adoc | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/docs/modules/ROOT/pages/aws-sns-fifo-sink.adoc b/docs/modules/ROOT/pages/aws-sns-fifo-sink.adoc
index a95c692..629bf65 100644
--- a/docs/modules/ROOT/pages/aws-sns-fifo-sink.adoc
+++ b/docs/modules/ROOT/pages/aws-sns-fifo-sink.adoc
@@ -7,6 +7,10 @@
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
+
== Configuration Options
The following table summarizes the configuration options available for the `aws-sns-fifo-sink` Kamelet:
[camel-kamelets] 01/03: Support Subject as header into sns fifo sink
Posted by ac...@apache.org.
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-kamelets.git
commit a6adb92af769702094de58ef518ea8c4d6f1f410
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Sep 14 12:17:48 2021 +0200
Support Subject as header into sns fifo sink
---
aws-sns-fifo-sink.kamelet.yaml | 19 ++++++++++++++++++-
1 file changed, 18 insertions(+), 1 deletion(-)
diff --git a/aws-sns-fifo-sink.kamelet.yaml b/aws-sns-fifo-sink.kamelet.yaml
index 6eee7a1..0c19c75 100644
--- a/aws-sns-fifo-sink.kamelet.yaml
+++ b/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}}"
[camel-kamelets] 02/03: Support Subject as header into sns fifo sink
Posted by ac...@apache.org.
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-kamelets.git
commit 6deed5063eda93ffffff5f49caabd9bc268baa67
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Sep 14 12:18:50 2021 +0200
Support Subject as header into sns fifo sink
---
.../resources/kamelets/aws-sns-fifo-sink.kamelet.yaml | 19 ++++++++++++++++++-
1 file changed, 18 insertions(+), 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
index 6eee7a1..0c19c75 100644
--- 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}}"