アンドロイドでpahoを持つMQTT、最初のメッセージのみを受信

Question

私はpahoでMQTTを使用してアンドロイドでメッセージを受信し公開しています。

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トピックに初めて投稿しました。私は何かを出版しているようではない。私がテストトピックスに別のメッセージを送ろうとすると、それは私のアンドロイドで受け取ることはありません。

誰でも私が現在欠いているものは何ですか？

ありがとうございます！

Answer 1

PAHOのデバッグ後、同じ問題が発生しましたが、client.publishは、messageArrived（...）コールバックを呼び出すスレッド以外のスレッドから呼び出されなければならないことがわかりました。デッドロックが発生するため、client.publish（...）はmessageArrived（...）コールバックコードから呼び出すことはできません。