Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

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
languagexml
 <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 propertyExample

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 .

usernamemqtt-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