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

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.