Uses of Class
org.apache.storm.mqtt.MqttMessage

Packages that use MqttMessage

Package	Description
org.apache.storm.mqtt
org.apache.storm.mqtt.common
org.apache.storm.mqtt.examples	MQTT examples.
org.apache.storm.mqtt.mappers

Uses of MqttMessage in org.apache.storm.mqtt

Methods in org.apache.storm.mqtt that return MqttMessage

Modifier and Type	Method and Description
MqttMessage	MqttTupleMapper.toMessage(ITuple tuple) Converts a Tuple to a MqttMessage.

Methods in org.apache.storm.mqtt with parameters of type MqttMessage

Modifier and Type	Method and Description
Values	MqttMessageMapper.toValues(MqttMessage message) Convert a `MqttMessage` to a set of Values that can be emitted as a Storm Tuple.

Uses of MqttMessage in org.apache.storm.mqtt.common

Methods in org.apache.storm.mqtt.common with parameters of type MqttMessage

Modifier and Type	Method and Description
void	MqttPublisher.publish(MqttMessage message)

Uses of MqttMessage in org.apache.storm.mqtt.examples

Methods in org.apache.storm.mqtt.examples with parameters of type MqttMessage

Modifier and Type	Method and Description
Values	CustomMessageMapper.toValues(MqttMessage message) Converts MQTT message to an instance of Values.

Uses of MqttMessage in org.apache.storm.mqtt.mappers

Methods in org.apache.storm.mqtt.mappers with parameters of type MqttMessage

Modifier and Type	Method and Description
Values	StringMessageMapper.toValues(MqttMessage message)
Values	ByteArrayMessageMapper.toValues(MqttMessage message)