org.apache.storm.mqtt

Interface MqttTupleMapper

All Superinterfaces:

Serializable

public interface MqttTupleMapper
extends Serializable

Given a Tuple, converts it to an MQTT message.

Method Summary

Modifier and Type	Method and Description
MqttMessage	toMessage(ITuple tuple) Converts a Tuple to a MqttMessage

Method Detail

toMessage

MqttMessage toMessage(ITuple tuple)

Converts a Tuple to a MqttMessage

Parameters:

tuple - the incoming tuple

Returns:

the message to publish