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
The following commit(s) were added to refs/heads/main by this push: new 398222c2 Add Support for Topic in Servicebus Kamelets 398222c2 is described below commit 398222c2df28d84ff7510ac6adc23212e270e9b2 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Tue Sep 5 17:38:05 2023 +0200 Add Support for Topic in Servicebus Kamelets Signed-off-by: Andrea Cosentino <anco...@gmail.com> --- kamelets/azure-servicebus-sink.kamelet.yaml | 7 +++++++ kamelets/azure-servicebus-source.kamelet.yaml | 7 +++++++ .../src/main/resources/kamelets/azure-servicebus-sink.kamelet.yaml | 7 +++++++ .../main/resources/kamelets/azure-servicebus-source.kamelet.yaml | 7 +++++++ 4 files changed, 28 insertions(+) diff --git a/kamelets/azure-servicebus-sink.kamelet.yaml b/kamelets/azure-servicebus-sink.kamelet.yaml index 37bb8dd1..28cba2a1 100644 --- a/kamelets/azure-servicebus-sink.kamelet.yaml +++ b/kamelets/azure-servicebus-sink.kamelet.yaml @@ -50,6 +50,12 @@ spec: x-descriptors: - urn:alm:descriptor:com.tectonic.ui:password - urn:camel:group:credentials + serviceBusType: + title: Servicebus Type + description: The service bus type of connection to execute. Queue is for typical queue option and topic for subscription based model. + type: string + default: queue + enum: ["queue", "topic"] types: in: mediaType: application/octet-stream @@ -65,4 +71,5 @@ spec: uri: "azure-servicebus:{{topicOrQueueName}}" parameters: connectionString: "{{connectionString}}" + serviceBusType: "{{serviceBusType}}" producerOperation: "sendMessages" diff --git a/kamelets/azure-servicebus-source.kamelet.yaml b/kamelets/azure-servicebus-source.kamelet.yaml index 29e0ea52..3cb6a35c 100644 --- a/kamelets/azure-servicebus-source.kamelet.yaml +++ b/kamelets/azure-servicebus-source.kamelet.yaml @@ -62,6 +62,12 @@ spec: 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 + serviceBusType: + title: Servicebus Type + description: The service bus type of connection to execute. Queue is for typical queue option and topic for subscription based model. + type: string + default: queue + enum: ["queue", "topic"] types: out: mediaType: application/octet-stream @@ -76,6 +82,7 @@ spec: connectionString: "{{connectionString}}" serviceBusReceiveMode: "{{serviceBusReceiveMode}}" subscriptionName: "{{?subscriptionName}}" + serviceBusType: "{{serviceBusType}}" steps: - set-body: simple: "${body.toBytes()}" diff --git a/library/camel-kamelets/src/main/resources/kamelets/azure-servicebus-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/azure-servicebus-sink.kamelet.yaml index 37bb8dd1..28cba2a1 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/azure-servicebus-sink.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/azure-servicebus-sink.kamelet.yaml @@ -50,6 +50,12 @@ spec: x-descriptors: - urn:alm:descriptor:com.tectonic.ui:password - urn:camel:group:credentials + serviceBusType: + title: Servicebus Type + description: The service bus type of connection to execute. Queue is for typical queue option and topic for subscription based model. + type: string + default: queue + enum: ["queue", "topic"] types: in: mediaType: application/octet-stream @@ -65,4 +71,5 @@ spec: uri: "azure-servicebus:{{topicOrQueueName}}" parameters: connectionString: "{{connectionString}}" + serviceBusType: "{{serviceBusType}}" producerOperation: "sendMessages" 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 29e0ea52..3cb6a35c 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 @@ -62,6 +62,12 @@ spec: 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 + serviceBusType: + title: Servicebus Type + description: The service bus type of connection to execute. Queue is for typical queue option and topic for subscription based model. + type: string + default: queue + enum: ["queue", "topic"] types: out: mediaType: application/octet-stream @@ -76,6 +82,7 @@ spec: connectionString: "{{connectionString}}" serviceBusReceiveMode: "{{serviceBusReceiveMode}}" subscriptionName: "{{?subscriptionName}}" + serviceBusType: "{{serviceBusType}}" steps: - set-body: simple: "${body.toBytes()}"