Package | Description |
---|---|
org.apache.storm.mqtt | |
org.apache.storm.mqtt.common | |
org.apache.storm.mqtt.examples |
MQTT examples.
|
org.apache.storm.mqtt.mappers |
Modifier and Type | Method and Description |
---|---|
MqttMessage |
MqttTupleMapper.toMessage(ITuple tuple)
Converts a Tuple to a MqttMessage
|
Modifier and Type | Method and Description |
---|---|
Values |
MqttMessageMapper.toValues(MqttMessage message)
Convert a
MqttMessage to a set of Values that can be emitted as a Storm Tuple. |
Modifier and Type | Method and Description |
---|---|
void |
MqttPublisher.publish(MqttMessage message) |
Modifier and Type | Method and Description |
---|---|
Values |
CustomMessageMapper.toValues(MqttMessage message)
Converts MQTT message to an instance of
Values . |
Modifier and Type | Method and Description |
---|---|
Values |
StringMessageMapper.toValues(MqttMessage message) |
Values |
ByteArrayMessageMapper.toValues(MqttMessage message) |
Copyright © 2019 The Apache Software Foundation. All rights reserved.