org.apache.storm.mqtt.examples

Class CustomMessageMapper

java.lang.Object

org.apache.storm.mqtt.examples.CustomMessageMapper

All Implemented Interfaces:

Serializable, MqttMessageMapper

public class CustomMessageMapper
extends Object
implements MqttMessageMapper

Given a topic name: “users/{user}/{location}/{deviceId}” and a payload of “{temperature}/{humidity}” emits a tuple containing user(String), deviceId(String), location(String), temperature(float), humidity(float)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CustomMessageMapper()

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

CustomMessageMapper

public CustomMessageMapper()

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.