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 12:57:41 UTC
[camel-kamelets] branch azure-storage-queue-source created (now 93f91625)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch azure-storage-queue-source
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at 93f91625 Duplicate some of headers with a different name - Azure Storage Queue Source
This branch includes the following new commits:
new d86f2689 Duplicate some of headers with a different name - Azure Storage Queue Source
new 93f91625 Duplicate some of headers with a different name - Azure Storage Queue Source
The 2 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.
[camel-kamelets] 01/02: Duplicate some of headers with a different name - Azure Storage Queue Source
Posted by ac...@apache.org.
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 <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"
[camel-kamelets] 02/02: Duplicate some of headers with a different name - Azure Storage Queue Source
Posted by ac...@apache.org.
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 93f916257b6640ffb61d2f16c48dd1a12209b3f6
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Oct 11 14:57:11 2022 +0200
Duplicate some of headers with a different name - Azure Storage Queue Source
---
.../main/resources/kamelets/azure-storage-queue-source.kamelet.yaml | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
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 96902ec0..1a5f6a79 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
@@ -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
@@ -76,7 +78,7 @@ spec:
- key: mode
value: 'filtering'
- key: selectedHeaders
- value: 'CamelAzureStorageQueueMessageId,CamelAzureStorageQueueInsertionTime'
+ value: 'CamelAzureStorageQueueMessageId'
from:
uri: "azure-storage-queue://{{accountName}}/{{queueName}}"
parameters: