Package org.apache.storm.mqtt.examples

Class Summary

Class	Description
CustomMessageMapper	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)
MqttBrokerPublisher