Выполнить действие в подписчике MQTT

Этот код подписчика mqtt работает нормально. Я могу легко подписаться на сообщения, которые публикуются на сайте broker.hivemq.com с соответствующей темой.

public class AccelerometerSubscriber  implements MqttCallback,  
IMqttActionListener {

public static void main(String[] args)  throws MqttException  {
int QUALITY_OF_SERVICE = 2;
MqttClient client=new MqttClient("tcp://broker.hivemq.com:1883", 
MqttClient.generateClientId());
client.setCallback( new SimpleMqttCallBack() );
client.connect();
System.out.println("Subscribing ....");
client.subscribe("MQTT Examples");    }

System.out.println("some action"); //------------right here--------------

public void connectionLost(Throwable throwable) {

System.out.println("Connection to MQTT broker lost!");  }


public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {

  System.out.println("Message received:\n\t"+ new String(mqttMessage.getPayload()) );

}   

 public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {

  // not used in this example

}}

Теперь я хочу выполнять действие только при получении сообщения. Я не могу этого сделать.


mqtt subscribe
person ephlux    schedule 16.08.2017    source источник

Ответы (1)


arrow_upward
0
arrow_downward

У вас есть класс (AccelerometerSubscriber), который реализует интерфейс MqttCallback, используйте его экземпляр вместо client.setCallback( new SimpleMqttCallBack() );

public class AccelerometerSubscriber implements MqttCallback, IMqttActionListener {

    public static void main(String[] args) throws MqttException {
        AccelerometerSubscriber as = new AccelerometerSubscriber();
        int QUALITY_OF_SERVICE = 2;
        MqttClient client = new MqttClient("tcp://broker.hivemq.com:1883", MqttClient.generateClientId());
        client.setCallback(as);
        client.connect();
        System.out.println("Subscribing ....");
        client.subscribe("MQTT Examples");
    }

    @Override
    public void connectionLost(Throwable throwable) {
        System.out.println("Connection to MQTT broker lost!");
    }
    @Override
    public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
        //message is received is here!!!
        System.out.println("Message received:\n\t" + new String(mqttMessage.getPayload()));
    }
    @Override
    public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
        System.out.println("deliveryComplete");
    }
    @Override
    public void onFailure(IMqttToken arg0, Throwable arg1) {
        System.out.println("onFailure");
    }
    @Override
    public void onSuccess(IMqttToken arg0) {
        System.out.println("onSuccess");
    }
}
person ΦXocę 웃 Пepeúpa ツ    schedule 16.08.2017