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/03/28 10:35:02 UTC

[camel-kamelets] 02/02: Azure Servicebus Souce Kamelet: Add subscriptionName as optional parameter for Topic

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

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

commit d9f37808bbb90f6d490112e2af4ae1726d392075
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Mar 28 12:30:22 2022 +0200

    Azure Servicebus Souce Kamelet: Add subscriptionName as optional parameter for Topic
---
 .../main/resources/kamelets/azure-servicebus-source.kamelet.yaml   | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/azure-servicebus-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/azure-servicebus-source.kamelet.yaml
index aafaf72..b202fe7 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/azure-servicebus-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/azure-servicebus-source.kamelet.yaml
@@ -32,6 +32,8 @@ spec:
     title: "Azure Servicebus Source"
     description: |-
       Consume Messages from Azure Servicebus.
+
+      The subscribtion name parameter needs to be populated in case of consuming from a Topic.
     required:
       - topicOrQueueName
       - connectionString
@@ -54,6 +56,10 @@ spec:
         description: Sets the receive mode for the receiver, possible values are PEEK_LOCK and RECEIVE_AND_DELETE
         type: String
         default: PEEK_LOCK
+      subscriptionName:
+        title: Subscription Name
+        description: Sets the name of the subscription in the topic to listen to. This parameter is mandatory in case of topic.
+        type: String
   types:
     out:
       mediaType: application/octet-stream
@@ -67,6 +73,7 @@ spec:
       parameters:
         connectionString: "{{connectionString}}"
         serviceBusReceiveMode: "{{serviceBusReceiveMode}}"
+        subscriptionName: "{{?subscriptionName}}"
       steps:
       - to: "kamelet:sink"