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 2022/10/06 09:56:57 UTC
[camel-kamelets] branch main updated (edf50dad -> b7692682)
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 edf50dad AWS SQS Source Kamelet: Add greedy parameter
new 66749b81 Duplicate some of headers with a different name - AWS SQS Source
new 13378951 Duplicate some of headers with a different name - AWS SQS Source
new b7692682 Duplicate some of headers with a different name - AWS SQS Source
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:
kamelets/aws-sqs-source.kamelet.yaml | 18 ++++++++++++++++++
.../camel/kamelets/catalog/KameletsCatalogTest.java | 2 +-
.../resources/kamelets/aws-sqs-source.kamelet.yaml | 18 ++++++++++++++++++
3 files changed, 37 insertions(+), 1 deletion(-)
[camel-kamelets] 02/03: Duplicate some of headers with a different name - AWS SQS Source
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 13378951e7f7fd300d0a805da76773045c911614
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 6 11:46:00 2022 +0200
Duplicate some of headers with a different name - AWS SQS Source
---
kamelets/aws-sqs-source.kamelet.yaml | 2 ++
1 file changed, 2 insertions(+)
diff --git a/kamelets/aws-sqs-source.kamelet.yaml b/kamelets/aws-sqs-source.kamelet.yaml
index 89fa2291..00846eb1 100644
--- a/kamelets/aws-sqs-source.kamelet.yaml
+++ b/kamelets/aws-sqs-source.kamelet.yaml
@@ -37,6 +37,8 @@ spec:
Access Key/Secret Key are the basic method for authenticating to the AWS SQS Service. These parameters are optional because the Kamelet provides the 'useDefaultCredentialsProvider'.
When using a default Credentials Provider the SQS client will load the credentials through this provider and won't use the static credential. This is reason for not having the access key and secret key as mandatory parameter for this Kamelet.
+
+ Two headers will be duplicated with different names for clarity at sink level, CamelAwsSqsMessageId will be duplicated into aws.sqs.message.id and CamelAwsSqsReceiptHandle will be duplicated in aws.sqs.receipt.handle
required:
- queueNameOrArn
- region
[camel-kamelets] 01/03: Duplicate some of headers with a different name - AWS SQS Source
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 66749b81940b3313f15fa5cea32725b99859fbf8
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 6 11:41:28 2022 +0200
Duplicate some of headers with a different name - AWS SQS Source
---
kamelets/aws-sqs-source.kamelet.yaml | 16 ++++++++++++++++
.../camel/kamelets/catalog/KameletsCatalogTest.java | 2 +-
.../main/resources/kamelets/aws-sqs-source.kamelet.yaml | 16 ++++++++++++++++
3 files changed, 33 insertions(+), 1 deletion(-)
diff --git a/kamelets/aws-sqs-source.kamelet.yaml b/kamelets/aws-sqs-source.kamelet.yaml
index c59f0c4f..89fa2291 100644
--- a/kamelets/aws-sqs-source.kamelet.yaml
+++ b/kamelets/aws-sqs-source.kamelet.yaml
@@ -137,9 +137,23 @@ spec:
- 'urn:alm:descriptor:com.tectonic.ui:checkbox'
default: false
dependencies:
+ - "camel:core"
- "camel:aws2-sqs"
+ - "github:apache.camel-kamelets:camel-kamelets-utils:main-SNAPSHOT"
- "camel:kamelet"
template:
+ beans:
+ - name: renameHeaders
+ type: "#class:org.apache.camel.kamelets.utils.headers.DuplicateNamingHeaders"
+ property:
+ - key: prefix
+ value: 'CamelAwsSqs'
+ - key: renamingPrefix
+ value: 'aws.sqs.'
+ - key: mode
+ value: 'filtering'
+ - key: selectedHeaders
+ value: 'CamelAwsSqsReceiptHandle,CamelAwsSqsMessageId'
from:
uri: "aws2-sqs:{{queueNameOrArn}}"
parameters:
@@ -156,4 +170,6 @@ spec:
delay: "{{delay}}"
greedy: "{{greedy}}"
steps:
+ - process:
+ ref: "{{renameHeaders}}"
- to: "kamelet:sink"
diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
index 31d21bbb..19811879 100644
--- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
+++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
@@ -102,7 +102,7 @@ public class KameletsCatalogTest {
@Test
void testGetKameletsDependencies() throws Exception {
List<String> deps = catalog.getKameletDependencies("aws-sqs-source");
- assertEquals(2, deps.size());
+ assertEquals(4, deps.size());
deps = catalog.getKameletDependencies("cassandra-sink");
assertEquals(3, deps.size());
assertEquals("camel:jackson", deps.get(0));
diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
index c59f0c4f..89fa2291 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
@@ -137,9 +137,23 @@ spec:
- 'urn:alm:descriptor:com.tectonic.ui:checkbox'
default: false
dependencies:
+ - "camel:core"
- "camel:aws2-sqs"
+ - "github:apache.camel-kamelets:camel-kamelets-utils:main-SNAPSHOT"
- "camel:kamelet"
template:
+ beans:
+ - name: renameHeaders
+ type: "#class:org.apache.camel.kamelets.utils.headers.DuplicateNamingHeaders"
+ property:
+ - key: prefix
+ value: 'CamelAwsSqs'
+ - key: renamingPrefix
+ value: 'aws.sqs.'
+ - key: mode
+ value: 'filtering'
+ - key: selectedHeaders
+ value: 'CamelAwsSqsReceiptHandle,CamelAwsSqsMessageId'
from:
uri: "aws2-sqs:{{queueNameOrArn}}"
parameters:
@@ -156,4 +170,6 @@ spec:
delay: "{{delay}}"
greedy: "{{greedy}}"
steps:
+ - process:
+ ref: "{{renameHeaders}}"
- to: "kamelet:sink"
[camel-kamelets] 03/03: Duplicate some of headers with a different name - AWS SQS Source
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 b7692682485e746c4945eb768dcbe45168ea336d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 6 11:47:32 2022 +0200
Duplicate some of headers with a different name - AWS SQS Source
---
.../src/main/resources/kamelets/aws-sqs-source.kamelet.yaml | 2 ++
1 file changed, 2 insertions(+)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
index 89fa2291..00846eb1 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
@@ -37,6 +37,8 @@ spec:
Access Key/Secret Key are the basic method for authenticating to the AWS SQS Service. These parameters are optional because the Kamelet provides the 'useDefaultCredentialsProvider'.
When using a default Credentials Provider the SQS client will load the credentials through this provider and won't use the static credential. This is reason for not having the access key and secret key as mandatory parameter for this Kamelet.
+
+ Two headers will be duplicated with different names for clarity at sink level, CamelAwsSqsMessageId will be duplicated into aws.sqs.message.id and CamelAwsSqsReceiptHandle will be duplicated in aws.sqs.receipt.handle
required:
- queueNameOrArn
- region