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

- Packages that use MqttMessageMapper
  Package | Description
  --- | ---
  org.apache.storm.mqtt.examples | 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)`

Copyright © 2021 The Apache Software Foundation. All rights reserved.