Operators: com.teracloud.streams.mqtt 3.0.0

Operators

MQTTSink
The MQTTSink operator creates a message for every tuple it receives on its input port and publishes the message to an MQTT server.
MQTTSource
The MQTTSource operator subscribes to MQTT topics and receives messages when they are published to subscribed topics.