Added Spring-RabbitMQ Sink and Source Kamelet

Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
apache · Feb 14, 2024 · 4621ff0 · 4621ff0
1 parent a4161d8
commit 4621ff0
Show file tree

Hide file tree

Showing 5 changed files with 18 additions and 12 deletions.
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
@@ -216,6 +216,8 @@
 * xref:splunk-hec-sink.adoc[]
 * xref:splunk-sink.adoc[]
 * xref:splunk-source.adoc[]
+* xref:spring-rabbitmq-sink.adoc[]
+* xref:spring-rabbitmq-source.adoc[]
 * xref:sqlserver-sink.adoc[]
 * xref:sqlserver-source.adoc[]
 * xref:ssh-sink.adoc[]

diff --git a/kamelets/spring-rabbitmq-sink.kamelet.yaml b/kamelets/spring-rabbitmq-sink.kamelet.yaml
@@ -33,7 +33,8 @@ spec:
     description: |-
       Send data to a RabbitMQ Broker.
     required:
-      - addresses
+      - host
+      - port
       - exchangeName
     type: object
     properties:
@@ -81,8 +82,8 @@ spec:
       - name: connectionFactory
         type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
         properties:
-          username: '{{username}}'
-          password: '{{password}}'
+          username: '{{?username}}'
+          password: '{{?password}}'
           host: '{{host}}'
           port: '{{port}}'
     from:

diff --git a/kamelets/spring-rabbitmq-source.kamelet.yaml b/kamelets/spring-rabbitmq-source.kamelet.yaml
@@ -33,7 +33,8 @@ spec:
     description: |-
       Receive data from a RabbitMQ Broker.
     required:
-      - addresses
+      - host
+      - port
       - exchangeName
     type: object
     properties:
@@ -86,8 +87,8 @@ spec:
       - name: connectionFactory
         type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
         properties:
-          username: '{{username}}'
-          password: '{{password}}'
+          username: '{{?username}}'
+          password: '{{?password}}'
           host: '{{host}}'
           port: '{{port}}'
     from:

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
@@ -33,7 +33,8 @@ spec:
     description: |-
       Send data to a RabbitMQ Broker.
     required:
-      - addresses
+      - host
+      - port
       - exchangeName
     type: object
     properties:
@@ -81,8 +82,8 @@ spec:
       - name: connectionFactory
         type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
         properties:
-          username: '{{username}}'
-          password: '{{password}}'
+          username: '{{?username}}'
+          password: '{{?password}}'
           host: '{{host}}'
           port: '{{port}}'
     from:

diff --git a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
@@ -33,7 +33,8 @@ spec:
     description: |-
       Receive data from a RabbitMQ Broker.
     required:
-      - addresses
+      - host
+      - port
       - exchangeName
     type: object
     properties:
@@ -86,8 +87,8 @@ spec:
       - name: connectionFactory
         type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
         properties:
-          username: '{{username}}'
-          password: '{{password}}'
+          username: '{{?username}}'
+          password: '{{?password}}'
           host: '{{host}}'
           port: '{{port}}'
     from: