Package org.apache.storm.mqtt.examples

MQTT examples.

See: Description

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	A MQTT example using a Storm topology.

Package org.apache.storm.mqtt.examples Description

MQTT examples.