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/11 13:05:00 UTC
[camel-kamelets] 01/04: Duplicate some of headers with a different name - Azure Storage Queue Source
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 2d3652151c055830e830e4d2379ecd3c6c0e04d4
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Oct 11 14:53:40 2022 +0200
Duplicate some of headers with a different name - Azure Storage Queue Source
---
kamelets/azure-storage-queue-source.kamelet.yaml | 16 ++++++++++++++++
.../kamelets/azure-storage-queue-source.kamelet.yaml | 14 ++++++++++++++
2 files changed, 30 insertions(+)
diff --git a/kamelets/azure-storage-queue-source.kamelet.yaml b/kamelets/azure-storage-queue-source.kamelet.yaml
index 40a4bf6c..1a5f6a79 100644
--- a/kamelets/azure-storage-queue-source.kamelet.yaml
+++ b/kamelets/azure-storage-queue-source.kamelet.yaml
@@ -32,6 +32,8 @@ spec:
title: "Azure Storage Queue Source"
description: |-
Receive events from Azure Storage queues.
+
+ One header will be duplicated with different names for clarity at sink level, CamelAzureStorageQueueMessageId will be duplicated into azure.storage.queue.message.id
required:
- accountName
- queueName
@@ -65,10 +67,24 @@ spec:
- "camel:azure-storage-queue"
- "camel:kamelet"
template:
+ beans:
+ - name: renameHeaders
+ type: "#class:org.apache.camel.kamelets.utils.headers.DuplicateNamingHeaders"
+ property:
+ - key: prefix
+ value: 'CamelAzureStorageQueue'
+ - key: renamingPrefix
+ value: 'azure.storage.queue.'
+ - key: mode
+ value: 'filtering'
+ - key: selectedHeaders
+ value: 'CamelAzureStorageQueueMessageId'
from:
uri: "azure-storage-queue://{{accountName}}/{{queueName}}"
parameters:
accessKey: "{{accessKey}}"
maxMessages: "{{maxMessages}}"
steps:
+ - process:
+ ref: "{{renameHeaders}}"
- to: "kamelet:sink"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-queue-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-queue-source.kamelet.yaml
index 40a4bf6c..96902ec0 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-queue-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-queue-source.kamelet.yaml
@@ -65,10 +65,24 @@ spec:
- "camel:azure-storage-queue"
- "camel:kamelet"
template:
+ beans:
+ - name: renameHeaders
+ type: "#class:org.apache.camel.kamelets.utils.headers.DuplicateNamingHeaders"
+ property:
+ - key: prefix
+ value: 'CamelAzureStorageQueue'
+ - key: renamingPrefix
+ value: 'azure.storage.queue.'
+ - key: mode
+ value: 'filtering'
+ - key: selectedHeaders
+ value: 'CamelAzureStorageQueueMessageId,CamelAzureStorageQueueInsertionTime'
from:
uri: "azure-storage-queue://{{accountName}}/{{queueName}}"
parameters:
accessKey: "{{accessKey}}"
maxMessages: "{{maxMessages}}"
steps:
+ - process:
+ ref: "{{renameHeaders}}"
- to: "kamelet:sink"