Paho Component
Available as of Camel 2.16
Paho component provides connector for the MQTT messaging protocol using the Paho library.
Adding the component to the project
Maven users will need to add the following dependency to their pom.xml
for this component:
<dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-paho</artifactId> <version>x.y.z</version> <!-- use the same version as your Camel core version --> </dependency>
URI format
paho:queueName[?options]
You can append query options to the URI in the following format: ?option=value&option=value&...
.
URI Options
Option | Default | Description |
---|---|---|
clientId | camel-<timestamp> | MQTT client identifier. |
|
| The URL of the MQTT broker. |
persistence | memory | Client persistence to be used - memory or file . |
qos | 2 | Client quality of service level (0 -2 ). |
Examples
Read messages from the MQTT broker installed on the same host as the Camel router:
Car.java
from("paho:some/queue"). to("mock:test");
Read messages from the remote MQTT broker:
Car.java
from("paho:some/queue?brokerUrl=tcp://iot.eclipse.org:1883"). to("mock:test");
Send message to the MQTT broker:
Car.java
from("direct:test"). to("paho:some/target/queue");