MQTT event receiver is an internal event receiver that comes with WSO2 products. You can configure it with XML, JSON, and text input mapping types.
...
- Download MQTT client library (
mqtt-client-0.4.0.jar). - Add the JAR file to the
<CEP<PRODUCT_HOME>/repository/components/lib/directory. - Start the MQTT-supported server.
...
You can also define the respective adapter properties of the event receiver based on the transport type within the <from> element of the event receiver configuration in the<CEPthe <PRODUCT_HOME>/repository/deployment/server/eventreceivers/ directory as follows.
...
Adapter Property | Description | Configuration file property | Example |
|---|---|---|---|
Topic | A valid name for the MQTT broker topic which is used to receive messages on the MQTT input event adapter. | topic | MQTTInputEventAdapter |
Broker Url | MQTT broker URL. You can use the same URL f or WSO2 MB (when offset is zero). | url | tcp://localhost:1883 |
| Username | A valid username for the broker connection. | username | mqtt-user |
| Password | A valid password for the broker connection. | password | mqtt-password |
| Clean Session | Persist topic subscriptions and acknowledge positions across client sessions. | cleanSession | true/false |
| Client Id | Unique client ID used by the server to identify a client when it reconnects. Used for durable subscriptions or reliable delivery of messages. | clientId | clientid |