public class MqttConsumer extends Object implements org.eclipse.paho.client.mqttv3.MqttCallback
Constructor and Description |
---|
MqttConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
connectionLost(Throwable t) |
void |
deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken iMqttDeliveryToken) |
static void |
main(String[] args) |
void |
messageArrived(String s,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) |
void |
runClient() |
public static void main(String[] args)
public void connectionLost(Throwable t)
connectionLost
in interface org.eclipse.paho.client.mqttv3.MqttCallback
public void messageArrived(String s, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) throws Exception
messageArrived
in interface org.eclipse.paho.client.mqttv3.MqttCallback
Exception
public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken iMqttDeliveryToken)
deliveryComplete
in interface org.eclipse.paho.client.mqttv3.MqttCallback
public void runClient()
Copyright © 2016 WSO2 Inc. All rights reserved.