Namespace `com.ibm.streamsx.mqtt`

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.

newControlSignal(MQTTSourceUpdate.TopicsUpdateAction, list<rstring>, uint32): Convenience method for creating a control signal that modifies subscription setting for MQTTSource operator

MQTTBlobMsg: Minimum Input/Output Stream Schema type for MQTT operators
MQTTRStringMsg: Minimum Input/Output Stream Schema type for MQTT operators
MQTTSinkUpdate.ControlPortType: The expected schema for the control input port in the MQTTSink operator
MQTTSourceUpdate.ControlPortType: Expected schema for the control input port of the MQTTSource operator
MQTTSourceUpdate.TopicsUpdateAction: Actions that can be applied to update the topics / Qos for MQTTSource operator
MQTTSourceUpdate.TopicsUpdateDesc: A descriptor to describe how the topics / qos should be updated in MQTTSource operator.