This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch spring-rabbitmq
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 1c6d609a9f1fe0357a58a33c647c015c633396b9
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Feb 14 14:11:04 2024 +0100
Added Spring-RabbitMQ Sink and Source Kamelet
Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
docs/modules/ROOT/nav.adoc | 2 ++
kamelets/spring-rabbitmq-sink.kamelet.yaml | 7 ++++---
kamelets/spring-rabbitmq-source.kamelet.yaml | 7 ++++---
.../src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml | 7 ++++---
.../main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml | 7 ++++---
5 files changed, 18 insertions(+), 12 deletions(-)
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index e60bc8a1..c8f6e470 100644
--- 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
index 1c0b3ef2..d2cf135d 100644
--- 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
index 78c94e4c..c4101166 100644
--- 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
index 1c0b3ef2..d2cf135d 100644
---
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
index 78c94e4c..c4101166 100644
---
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:
