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"
