package com.yang.eto1.CordovaPlugin;

import org.eclipse.paho.client.mqttv3.MqttCallback;

public class MqttCallbackHandler implements MqttCallback {
  @Override
  public void connectionLost(Throwable cause) {
//	  cause.printStackTrace();
    if (cause != null) {
    }
  }

  @Override
  public void messageArrived(String topic, MqttMessage message) throws Exception {
	  
  }

  @Override
  public void deliveryComplete(IMqttDeliveryToken token) {
    // Do nothing
  }

}

@@ -82,16 +82,125 @@
 allback;
+%0Aimport org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;%0Aimport org.eclipse.paho.client.mqttv3.MqttMessage;
 %0A%0Apublic

fix import bug