[camel-kamelets] 01/02: Duplicate some of headers with a different name - Azure Storage Queue Source

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch azure-storage-queue-source
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit d86f2689c65e9d000412fe836eae7bfa6aa290d8
Author: Andrea Cosentino <anco...@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"