（Androidアプリで）fusesourcemqtt-client-java1.4-uber-1.0の使用に問題があります。間違ったIPを指定した場合、またはmqttブローカーが適切なIPで実行されていない場合、「接続できませんでした（コールバック）」というメッセージが表示されますが、「接続できませんでした（リスナー）」というメッセージは表示されません。適切なIPを提供し、ブローカーが実行されている場合、アラートはまったく表示されません。リスナーがまったく機能せず、どういうわけか接続の成功コールバックが8にならないと思います。アイデアはありますか？アンドロイドアクティビティの完全なコードの下。
私はこのバージョンのmqtt-clientを使用しています：mqtt-client-java1.4-uber-1.0.jar RSMBとMosquitto であるさまざまなメッセブローカー（サーバー）も試しました
package racenet.mqtt;
import java.net.URISyntaxException;
import org.fusesource.hawtbuf.Buffer;
import org.fusesource.hawtbuf.UTF8Buffer;
import org.fusesource.mqtt.client.Callback;
import org.fusesource.mqtt.client.CallbackConnection;
import org.fusesource.mqtt.client.Listener;
import org.fusesource.mqtt.client.MQTT;
import racenet.mqtt.R;
import android.app.Activity;
import android.app.AlertDialog;
import android.os.Bundle;
public class MQTTActivity extends Activity {
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
MQTT mqtt = new MQTT();
try {
mqtt.setHost("tcp://proper-ip-here:1883");
} catch (URISyntaxException e) {
new AlertDialog.Builder(MQTTActivity.this)
.setMessage("Could not set host")
.setNeutralButton("OK", null)
.show();
}
final CallbackConnection connection = mqtt.callbackConnection();
connection.listener(new Listener() {
public void onConnected() {
new AlertDialog.Builder(MQTTActivity.this)
.setMessage("Connected (listener)")
.setNeutralButton("OK", null)
.show();
}
public void onDisconnected() {
new AlertDialog.Builder(MQTTActivity.this)
.setMessage("Disconnected (listener)")
.setNeutralButton("OK", null)
.show();
}
public void onFailure(Throwable arg0) {
new AlertDialog.Builder(MQTTActivity.this)
.setMessage("Failure (listener)")
.setNeutralButton("OK", null)
.show();
}
public void onPublish(UTF8Buffer arg0, Buffer arg1, Runnable arg2) {
new AlertDialog.Builder(MQTTActivity.this)
.setMessage("Publish (listener)")
.setNeutralButton("OK", null)
.show();
}
});
connection.connect(new Callback<Void>() {
public void onFailure(Throwable value) {
new AlertDialog.Builder(MQTTActivity.this)
.setMessage("Could not connect (callback)")
.setNeutralButton("OK", null)
.show();
}
public void onSuccess(Void v) {
new AlertDialog.Builder(MQTTActivity.this)
.setMessage("Connected (callback)")
.setNeutralButton("OK", null)
.show();
}
});
}
}