MQTT с paho на android, только получая первое сообщение

Question

Я использую MQTT с paho для приема и публикации сообщений на Android.

У меня есть следующий код для инициализации MQTT.

private void initializeMQTT(){ 
    try{ 
     mqttClient = new MqttClient(
       "tcp://broker.hivemq.com:1883", 
       MqttClient.generateClientId(), 
       new MemoryPersistence() 
     ); 

     mqttClient.connect(); 
     mqttConnected = mqttClient.isConnected(); 
     mqttClient.subscribe("testtopic/listen",1); 

     mqttClient.setCallback(new MqttCallback() { 
      @Override 
      public void connectionLost(Throwable cause) { //Called when the client lost the connection to the broker 
      } 

      @Override 
      public void messageArrived(String topic, MqttMessage message) throws Exception { 
       mqttPayload = topic + ": " + Arrays.toString(message.getPayload()); 
       mqttAnswer.setPayload(mqttPayload.getBytes()); 
       mqttClient.publish("testtopic/publish",mqttAnswer); 
      } 

      @Override 
      public void deliveryComplete(IMqttDeliveryToken token) {//Called when a outgoing publish is complete 
       messageInfoTest = "message was sent"; 
      } 
     }); 
    } 
    catch(MqttException e){ 

    } 

} 

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

Что происходит прямо сейчас, я получаю первый раз, когда публикую тему testtopic/receive. Кажется, я ничего не публикую. И если я попытаюсь отправить другое сообщение testtopic/receive, он никогда не получит на моем андроиде.

У кого-нибудь есть представление о том, чего я в настоящее время не хватает?

Спасибо!

Answer 1

У меня была такая же проблема, после того как отладка PAHO обнаружила, что client.publish должен вызываться из другого потока, кроме потока, вызывающего messageArrived (...) обратного вызова. client.publish (...) нельзя вызывать из messageArrived (...) кода обратного вызова, поскольку он вызывает тупик.