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:49:08 UTC
[camel-kamelets] 01/03: Duplicate some of headers with a different name - AWS SQS Source
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 1071-sqs
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 5ef868354d914d70002049afe0813d5ac7021b9c
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"