Мой код:
public void connect() throws MqttException {
MqttConnectOptions options = new MqttConnectOptions();
options.setUserName("user");
options.setPassword("pass".toCharArray());
options.setAutomaticReconnect(true);
MqttClient client = new MqttClient("tcp://broker:8884", MqttClient.generateClientId(), handlerPahoDirs());
client.setCallback(callback);
client.connect(options);
client.subscribe(this.topic);
}
и connectionLost
на MqttCallback :
public void connectionLost(Throwable throwable) {
try {
connect();
} catch (MqttException e) {
//Logger
}
}
Оказывается, что connectionLost()
никогда не получитсяназывается!Иногда я отключал интернет, и ни один из этих методов не вызывался (я был в режиме отладки).Что это может быть?