[camel-kamelets] branch main updated: Updated rabbitmq-source.kamelet.yaml

[ac...@apache.org]

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 022c491  Updated rabbitmq-source.kamelet.yaml
022c491 is described below

commit 022c491857d251ab46a664f33a9fda30d6575024
Author: Andrea Tarocchi <an...@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"