Namespace com.ibm.streamsx.messaging.mqtt

IBMStreams com.ibm.streamsx.messaging Toolkit > com.ibm.streamsx.messaging 5.4.3 > com.ibm.streamsx.messaging.mqtt

Deprecation of MQTT functions

The MQTT functions (operators, functions, SPL types) of this toolkit available in the com.ibm.streamsx.messaging.mqtt SPL namespace is deprecated. Please migrate to the streamsx.mqtt toolkit.

Operator control input port

Operators

• MQTTSink: DEPRECATED: The com.ibm.streamsx.messaging.mqtt.MQTTSink operator is deprecated and is replaced by the com.ibm.streamsx.mqtt.MQTTSink operator in the com.ibm.streamsx.mqtt toolkit. The deprecated operator might be removed in a future release.
• MQTTSource: DEPRECATED: The com.ibm.streamsx.messaging.mqtt.MQTTSource operator is deprecated and is replaced by the com.ibm.streamsx.mqtt.MQTTSource operator in the com.ibm.streamsx.mqtt toolkit. The deprecated operator might be removed in a future release.

Functions

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

Types

• 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.