This is an automated email from the ASF dual-hosted git repository.
nferraro pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit e96f17f0e55f114944b149816089339c90c5b8d9
Author: nicolaferraro <ni.ferr...@gmail.com>
AuthorDate: Mon Oct 18 18:36:10 2021 +0200
Fix #544: Create an MQTT sink
---
mqtt-sink.kamelet.yaml | 43 +++++++++++++++++++++++++++++++++++++++++++
1 file changed, 43 insertions(+)
diff --git a/mqtt-sink.kamelet.yaml b/mqtt-sink.kamelet.yaml
new file mode 100644
index 0000000..e279e74
--- /dev/null
+++ b/mqtt-sink.kamelet.yaml
@@ -0,0 +1,43 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+ name: mqtt-sink
+ annotations:
+ camel.apache.org/kamelet.support.level: "Preview"
+ camel.apache.org/catalog.version: "main-SNAPSHOT"
+ camel.apache.org/kamelet.icon:
"data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0idXRmLTgiPz4KPCEtLSBHZW5lcmF0b3I6IEFkb2JlIElsbHVzdHJhdG9yIDI0LjMuMCwgU1ZHIEV4cG9ydCBQbHVnLUluIC4gU1ZHIFZlcnNpb246IDYuMDAgQnVpbGQgMCkgIC0tPgo8c3ZnIHZlcnNpb249IjEuMiIgYmFzZVByb2ZpbGU9InRpbnkiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgeG1sbnM6eGxpbms9Imh0dHA6Ly93d3cudzMub3JnLzE5OTkveGxpbmsiIHg9IjBweCIKCSB5PSIwcHgiIHZpZXdCb3g9IjAgMCAzMjAgMzIwIiBvdmVyZmxvdz0idmlzaWJsZSIgeG1sOnNwYWNlPSJwcm
[...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ camel.apache.org/kamelet.group: "MQTT"
+ labels:
+ camel.apache.org/kamelet.type: "sink"
+spec:
+ definition:
+ title: "MQTT Sink"
+ description: |-
+ Allows sending messages to any endpoint that supports the MQTT protocol,
such as a message broker.
+ required:
+ - topic
+ - brokerUrl
+ type: object
+ properties:
+ topic:
+ title: Topic
+ description: The topic to send messages to
+ type: string
+ example: "mytopic"
+ brokerUrl:
+ title: Broker URL
+ description: The URL of the broker where to establish the connection
+ type: string
+ example: "tcp://mosquitto:1883"
+ dependencies:
+ - "camel:paho"
+ - "camel:kamelet"
+ flow:
+ from:
+ uri: kamelet:source
+ steps:
+ - to:
+ uri: paho:{{topic}}
+ parameters:
+ brokerUrl: "{{brokerUrl}}"
