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 265a8f5d3ced61765dbd7ac1027c0337b6d18cb9 Author: Andrea Cosentino <[email protected]> AuthorDate: Wed May 28 18:21:01 2025 +0200 Support TLS on RabbitMQ Kamelets - Sink Signed-off-by: Andrea Cosentino <[email protected]> --- kamelets/spring-rabbitmq-sink.kamelet.yaml | 9 +++++++-- .../main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml | 9 +++++++-- 2 files changed, 14 insertions(+), 4 deletions(-) diff --git a/kamelets/spring-rabbitmq-sink.kamelet.yaml b/kamelets/spring-rabbitmq-sink.kamelet.yaml index bbc6758f6..d299ff117 100644 --- a/kamelets/spring-rabbitmq-sink.kamelet.yaml +++ b/kamelets/spring-rabbitmq-sink.kamelet.yaml @@ -84,6 +84,12 @@ spec: description: The virtual host type: string default: "/" + protocol: + title: Protocol + description: The AMQP protocol to use. + type: string + enum: ["amqp", "amqps"] + default: "amqp" dependencies: - "camel:spring-rabbitmq" - "camel:kamelet" @@ -94,8 +100,7 @@ spec: properties: username: '{{?username}}' password: '{{?password}}' - host: '{{host}}' - port: '{{port}}' + uri: '{{protocol}}://{{host}}:{{port}}' virtualHost: "{{vhost}}" from: uri: "kamelet:source" diff --git a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml index bbc6758f6..d299ff117 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml @@ -84,6 +84,12 @@ spec: description: The virtual host type: string default: "/" + protocol: + title: Protocol + description: The AMQP protocol to use. + type: string + enum: ["amqp", "amqps"] + default: "amqp" dependencies: - "camel:spring-rabbitmq" - "camel:kamelet" @@ -94,8 +100,7 @@ spec: properties: username: '{{?username}}' password: '{{?password}}' - host: '{{host}}' - port: '{{port}}' + uri: '{{protocol}}://{{host}}:{{port}}' virtualHost: "{{vhost}}" from: uri: "kamelet:source"
