Package org.apache.storm.mqtt.mappers

Class Summary

Class	Description
ByteArrayMessageMapper
StringMessageMapper	Given a String topic and byte[] message, emits a tuple with fields “topic” and “message”, both of which are Strings.