Uses of Interface
org.apache.storm.mqtt.MqttMessageMapper

Packages that use MqttMessageMapper

Package	Description
org.apache.storm.mqtt.examples
org.apache.storm.mqtt.mappers
org.apache.storm.mqtt.spout

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

Classes in org.apache.storm.mqtt.examples that implement MqttMessageMapper

Modifier and Type	Class and Description
class	CustomMessageMapper Given a topic name: “users/{user}/{location}/{deviceId}” and a payload of “{temperature}/{humidity}” emits a tuple containing user(String), deviceId(String), location(String), temperature(float), humidity(float)

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

Classes in org.apache.storm.mqtt.mappers that implement MqttMessageMapper

Modifier and Type	Class and Description
class	ByteArrayMessageMapper
class	StringMessageMapper Given a String topic and byte[] message, emits a tuple with fields “topic” and “message”, both of which are Strings.

Uses of MqttMessageMapper in org.apache.storm.mqtt.spout

Fields in org.apache.storm.mqtt.spout declared as MqttMessageMapper

Modifier and Type	Field and Description
protected MqttMessageMapper	MqttSpout.type

Constructors in org.apache.storm.mqtt.spout with parameters of type MqttMessageMapper

Constructor and Description
MqttSpout(MqttMessageMapper type, MqttOptions options)
MqttSpout(MqttMessageMapper type, MqttOptions options, KeyStoreLoader keyStoreLoader)