org.apache.storm.mqtt

## Interface MqttMessageMapper

- All Superinterfaces:
    Serializable
  All Known Implementing Classes:
    ByteArrayMessageMapper, CustomMessageMapper, StringMessageMapper

      public interface MqttMessageMapper
      extends Serializable

  Represents an object that can be converted to a Storm Tuple from an AckableMessage, given a MQTT Topic Name and a byte array payload.

- - ### Method Summary

    All Methods Instance Methods Abstract Methods
    Modifier and Type | Method and Description
    --- | ---
    `Fields` | `outputFields()` Returns the list of output fields this Mapper produces.
    `Values` | `toValues(MqttMessage message)` Convert a `MqttMessage` to a set of Values that can be emitted as a Storm Tuple.

- - ### Method Detail

    - #### toValues

          Values toValues(MqttMessage message)

      Convert a `MqttMessage` to a set of Values that can be emitted as a Storm Tuple.

      Parameters:
        `message` - An MQTT Message.
      Returns:
        Values representing a Storm Tuple.

    - #### outputFields

          Fields outputFields()

      Returns the list of output fields this Mapper produces.

      Returns:
        the list of output fields this mapper produces.

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