Paho соединение потерял никогда не стреляя - PullRequest
0 голосов
/ 19 февраля 2019

Мой код:

 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() никогда не получитсяназывается!Иногда я отключал интернет, и ни один из этих методов не вызывался (я был в режиме отладки).Что это может быть?

...