Package org.apache.storm.mqtt

Interface Summary

Interface	Description
MqttMessageMapper	Represents an object that can be converted to a Storm Tuple from an AckableMessage, given a MQTT Topic Name and a byte array payload.
MqttTupleMapper	Given a Tuple, converts it to an MQTT message.

Class Summary

Class	Description
MqttLogger	Wrapper around SLF4J logger that allows MQTT messages to be logged.
MqttMessage	Represents an MQTT Message consisting of a topic string (e.g.