This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch rabbitmq-source in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 7968c75d706440678de24271ddf9112ecf251c40 Author: Andrea Tarocchi <and...@tarocch.it> AuthorDate: Sun Sep 12 22:34:09 2021 +0200 Updated rabbitmq-source.kamelet.yaml Added queue and routingKey as additional optional parameters, adjusted required parameter list. --- rabbitmq-source.kamelet.yaml | 21 ++++++++++++--------- 1 file changed, 12 insertions(+), 9 deletions(-) diff --git a/rabbitmq-source.kamelet.yaml b/rabbitmq-source.kamelet.yaml index c210cd0..be6ea1c 100644 --- a/rabbitmq-source.kamelet.yaml +++ b/rabbitmq-source.kamelet.yaml @@ -18,19 +18,17 @@ spec: required: - addresses - exchangeName - - username - - password type: object properties: addresses: title: Addresses description: Comma separated list of RabbitMQ broker addresses type: string - portNumber: - title: Port Number - description: Port of the RabbitMQ server + example: "localhost:5672" + routingKey: + title: Routing Key + description: The routing key to use when binding a consumer queue to the exchange type: string - default: 5672 username: title: Username description: The username to access the RabbitMQ server @@ -46,6 +44,10 @@ spec: title: Exchange name description: The exchange name determines the exchange the queue will be bound to type: string + queue: + title: Queue name + description: The queue to receive messages from + type: string dependencies: - "camel:rabbitmq" - "camel:kamelet" @@ -53,9 +55,10 @@ spec: from: uri: "rabbitmq://{{exchangeName}}" parameters: - password: "{{password}}" - username: "{{username}}" + password: "{{?password}}" + username: "{{?username}}" addresses: "{{addresses}}" - portNumber: "{{portNumber}}" + routingKey: "{{?routingKey}}" + queue: "{{?queue}}" steps: - to: "kamelet:sink"