You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/03/09 07:43:53 UTC
[camel-kamelets] 01/02: Added RabbitMQ Source Kamelet
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch rabbitmq
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit f36ec11e08f46edd6dda104f4122376b0cbe6103
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 9 08:43:00 2021 +0100
Added RabbitMQ Source Kamelet
---
rabbitmq-source.kamelet.yaml | 54 ++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 54 insertions(+)
diff --git a/rabbitmq-source.kamelet.yaml b/rabbitmq-source.kamelet.yaml
new file mode 100644
index 0000000..51bc561
--- /dev/null
+++ b/rabbitmq-source.kamelet.yaml
@@ -0,0 +1,54 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+ name: rabbitmq-source
+ annotations:
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iMjcxcHgiIGhlaWdodD0iMjcxcHgiIHZpZXdCb3g9Ii03LjUgMCAyNzEgMjcxIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHByZXNlcnZlQXNwZWN0UmF0aW89InhNaWRZTWlkIj48cGF0aCBkPSJNMjQ1LjQ0IDEwOC4zMDhoLTg1LjA5YTcuNzM4IDcuNzM4IDAgMCAxLTcuNzM1LTcuNzM0di04OC42OEMxNTIuNjE1IDUuMzI3IDE0Ny4yOSAwIDE0MC43MjYgMGgtMzAuMzc1Yy02LjU2OCAwLTExLjg5IDUuMzI3LTExLjg5IDExLjg5NHY4OC4xNDNjMCA0LjU3My0zLjY5NyA4LjI5LTguMjcgOC4zMWwtMjcuODg1LjEzM2MtNC42MT [...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ labels:
+ camel.apache.org/kamelet.type: "source"
+spec:
+ definition:
+ title: "RabbitMQ Source"
+ description: |-
+ Receive data from an RabbitMQ Brokers.
+ required:
+ - addresses
+ - exchangeName
+ - username
+ - password
+ properties:
+ addresses:
+ title: Addresses
+ description: Comma separated list of RabbitMQ broker addresses
+ type: string
+ port:
+ title: Port
+ description: Port of the RabbitMQ server
+ type: string
+ default: 5672
+ username:
+ title: Username
+ description: The username to access the RabbitMQ server
+ type: string
+ password:
+ title: Password
+ description: The password to access the RabbitMQ server
+ type: string
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ exchangeName:
+ title: Exchange name
+ description: The exchange name determines the exchange the queue will be bound to
+ type: string
+ flow:
+ from:
+ uri: "rabbitmq://{{exchangeName}}"
+ parameters:
+ password: "{{password}}"
+ username: "{{username}}"
+ addresses: "{{addresses}}"
+ steps:
+ - convert-body-to:
+ type: "java.lang.String"
+ - to: "kamelet:sink"