Package com.ibm.streamsx.topology.messaging.mqtt

Support for integrating with the MQTT messaging system http://mqtt.org.

See: Description

Class Summary

Class	Description
MqttStreams	A simple connector to a MQTT broker for publishing TStream<Message> tuples to MQTT topics, and subscribing to MQTT topics and creating TStream<Message> streams.

Package com.ibm.streamsx.topology.messaging.mqtt Description

Support for integrating with the MQTT messaging system http://mqtt.org.

MqttStreams is a connector to bridge between topology streams and a MQTT broker.

Functionality in this package is provided by the open source SPL toolkit com.ibm.streamsx.messaging release 2.0.0 or later. This requires that the com.ibm.streamsx.messaging toolkit is made available when submitting the application, by either:

• Submitting to an IBM Streams 4.0 or later instance.
• Including the toolkit in the toolkit path specified by the environment variable STREAMS_SPLPATH
• Specifically adding the toolkit using SPL.addToolkit(com.ibm.streamsx.topology.TopologyElement, java.io.File).

Releases of the toolkit are available from: https://github.com/IBMStreams/streamsx.messaging/releases.