org.apache.storm.mqtt.mappers

Class ByteArrayMessageMapper

java.lang.Object

org.apache.storm.mqtt.mappers.ByteArrayMessageMapper

All Implemented Interfaces:

Serializable, MqttMessageMapper

public class ByteArrayMessageMapper
extends Object
implements MqttMessageMapper

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ByteArrayMessageMapper()

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ByteArrayMessageMapper

public ByteArrayMessageMapper()

Method Detail

toValues

public Values toValues(MqttMessage message)

Description copied from interface: MqttMessageMapper

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

Specified by:

toValues in interface MqttMessageMapper

Parameters:

message - An MQTT Message.

Returns:

Values representing a Storm Tuple.

outputFields

public Fields outputFields()

Description copied from interface: MqttMessageMapper

Returns the list of output fields this Mapper produces.

Specified by:

outputFields in interface MqttMessageMapper

Returns:

the list of output fields this mapper produces.