MQTT Javaが複数回送信できない

Question

問題は、クライアントがメッセージを受信した後に最初のメッセージを送信したときに、メッセージを受信して​​応答できなくなることです。ここで

は、コードは次のとおりです。

public void demo() { 
    try { 
     client = new MqttClient("tcp://broker:1883", "Sending"); 
     client.connect(); 
     client.setCallback(this); 
     client.subscribe("receive"); 
    } catch (MqttException e) {} 
} 


@Override 
public void messageArrived(String topic, MqttMessage message) 
     throws Exception {  
    message.setPayload("I'm replying".getBytes()); 
    client.publish("publish", message); 
} 

私はAndroidの開発に似た何かを持っているし、それが魅力のように動作します。 Paho 3-1.0.2

Answer 1

からの新しいメッセージをmassageArrivedコールバックに公開しないでください。

使用する別のスレッド

編集から公開を行うにAsyncTaskのようなもの、申し訳ありませんが、100％の目を覚まし、ミスがAndroidのビットに読んでいません。残りの部分はまだ保持されています。通常のJavaではAsyncTaskではなく、ExcutorとRunnableを使用する必要があります