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.
| 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. |
Values toValues(MqttMessage message)
Convert a MqttMessage to a set of Values that can be emitted as a Storm Tuple.
message - An MQTT Message.Fields outputFields()
Returns the list of output fields this Mapper produces.
Copyright © 2021 The Apache Software Foundation. All rights reserved.