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.
...
Code Block | ||
---|---|---|
| ||
<eventReceiver name="mqttEventReceiverMQTTInputEventAdapter" statistics="disable" trace="disable" xmlns="http://wso2.org/carbon/eventreceiver"> <from eventAdapterType="mqtt"> <property name="topic">sensordata</property> <property name="clientId">CEP-CONSUMER</property> <property name="url">tcp://localhost:1883</property> <property name="username">mqtt-user</property> <property name="password">mqtt-password</property> <property name="cleanSession">true</property> </from> ...................... </eventReceiver> |
...
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 |