org.apache.storm.mqtt.examples

Class CustomMessageMapper

java.lang.Object

org.apache.storm.mqtt.examples.CustomMessageMapper

All Implemented Interfaces:

Serializable, MqttMessageMapper

public final 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() Constructor.

Method Summary

Modifier and Type	Method and Description
Fields	outputFields() Gets the output fields.
Values	toValues(MqttMessage message) Converts MQTT message to an instance of Values.

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomMessageMapper

public CustomMessageMapper()

Constructor.

Method Detail

toValues

public Values toValues(MqttMessage message)

Converts MQTT message to an instance of Values.

Specified by:

toValues in interface MqttMessageMapper

Parameters:

message - the message to convert

Returns:

the converted values

outputFields

public Fields outputFields()

Gets the output fields.

Specified by:

outputFields in interface MqttMessageMapper

Returns:

the output fields