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 <[email protected]> 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"
