Spring RabbitMQ Sink Kamelet: Support autoDeclareProducer as parameter (

#1944) Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
apache · Mar 12, 2024 · 4442fac · 4442fac
1 parent 8469401
commit 4442fac
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/kamelets/spring-rabbitmq-sink.kamelet.yaml b/kamelets/spring-rabbitmq-sink.kamelet.yaml
@@ -74,6 +74,11 @@ spec:
         title: Queue name
         description: The queue to receive messages from
         type: string
+      autoDeclareProducer:
+        title: Auto Declare Producer
+        description: Specifies whether the producer should auto declare binding between exchange, queue and routing key when starting
+        type: boolean
+        default: false
   dependencies:
     - "camel:spring-rabbitmq"
     - "camel:kamelet"
@@ -95,3 +100,4 @@ spec:
             connectionFactory: "#bean:{{connectionFactory}}"
             routingKey: "{{?routingKey}}"
             queues: "{{?queues}}"
+            autoDeclareProducer: "{{autoDeclareProducer}}"
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
@@ -74,6 +74,11 @@ spec:
         title: Queue name
         description: The queue to receive messages from
         type: string
+      autoDeclareProducer:
+        title: Auto Declare Producer
+        description: Specifies whether the producer should auto declare binding between exchange, queue and routing key when starting
+        type: boolean
+        default: false
   dependencies:
     - "camel:spring-rabbitmq"
     - "camel:kamelet"
@@ -95,3 +100,4 @@ spec:
             connectionFactory: "#bean:{{connectionFactory}}"
             routingKey: "{{?routingKey}}"
             queues: "{{?queues}}"
+            autoDeclareProducer: "{{autoDeclareProducer}}"