You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/06/29 10:47:31 UTC
[camel] branch main updated: [DOCS] Fix typos in paho-mqtt5 component docs (#7927)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 86dc42689e1 [DOCS] Fix typos in paho-mqtt5 component docs (#7927)
86dc42689e1 is described below
commit 86dc42689e1767c258763eafac2e22faefac07d0
Author: Lucia Drozdová <89...@users.noreply.github.com>
AuthorDate: Wed Jun 29 12:47:25 2022 +0200
[DOCS] Fix typos in paho-mqtt5 component docs (#7927)
---
.../src/main/docs/paho-mqtt5-component.adoc | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/components/camel-paho-mqtt5/src/main/docs/paho-mqtt5-component.adoc b/components/camel-paho-mqtt5/src/main/docs/paho-mqtt5-component.adoc
index 1584a4c839e..bc2c3c93f23 100644
--- a/components/camel-paho-mqtt5/src/main/docs/paho-mqtt5-component.adoc
+++ b/components/camel-paho-mqtt5/src/main/docs/paho-mqtt5-component.adoc
@@ -65,11 +65,11 @@ extracted out of (or put into) the MQTT message:
[source,java]
----
// Receive payload
-byte[] payload = (byte[]) consumerTemplate.receiveBody("paho:topic");
+byte[] payload = (byte[]) consumerTemplate.receiveBody("paho-mqtt5:topic");
// Send payload
byte[] payload = "message".getBytes();
-producerTemplate.sendBody("paho:topic", payload);
+producerTemplate.sendBody("paho-mqtt5:topic", payload);
----
But of course Camel build-in xref:manual::type-converter.adoc[type conversion
@@ -80,11 +80,11 @@ example below Camel automatically converts binary payload into `String`
[source,java]
----
// Receive payload
-String payload = consumerTemplate.receiveBody("paho:topic", String.class);
+String payload = consumerTemplate.receiveBody("paho-mqtt5:topic", String.class);
// Send payload
String payload = "message";
-producerTemplate.sendBody("paho:topic", payload);
+producerTemplate.sendBody("paho-mqtt5:topic", payload);
----
@@ -95,7 +95,7 @@ installed on the same host as the Camel router:
[source,java]
----
-from("paho:some/queue")
+from("paho-mqtt5:some/queue")
.to("mock:test");
----
@@ -104,14 +104,14 @@ While the snippet below sends message to the MQTT broker:
[source,java]
----
from("direct:test")
- .to("paho:some/target/queue");
+ .to("paho-mqtt5:some/target/queue");
----
For example this is how to read messages from the remote MQTT broker:
[source,java]
----
-from("paho:some/queue?brokerUrl=tcp://iot.eclipse.org:1883")
+from("paho-mqtt5:some/queue?brokerUrl=tcp://iot.eclipse.org:1883")
.to("mock:test");
----
@@ -121,7 +121,7 @@ And here we override the default topic and set to a dynamic topic
----
from("direct:test")
.setHeader(PahoConstants.CAMEL_PAHO_OVERRIDE_TOPIC, simple("${header.customerId}"))
- .to("paho:some/target/queue");
+ .to("paho-mqtt5:some/target/queue");
----