public class MQTTSubscriber
extends java.lang.Object
implements java.lang.Runnable
| Constructor and Description |
|---|
MQTTSubscriber(java.util.ArrayList<java.lang.String> topics,
org.fusesource.mqtt.client.MQTT mqtt,
MQTTCommunication com)
Instantiates a new MQTT subscriber.
|
MQTTSubscriber(org.fusesource.mqtt.client.MQTT mqtt,
MQTTCommunication com)
Instantiates a new MQTT subscriber.
|
| Modifier and Type | Method and Description |
|---|---|
void |
run() |
void |
subscribe(java.util.ArrayList<java.lang.String> topics)
Subscribe.
|
public MQTTSubscriber(org.fusesource.mqtt.client.MQTT mqtt,
MQTTCommunication com)
mqtt - the mqttcom - the compublic MQTTSubscriber(java.util.ArrayList<java.lang.String> topics,
org.fusesource.mqtt.client.MQTT mqtt,
MQTTCommunication com)
topics - the topicsmqtt - the mqttcom - the com