Fix NPE in MqttClient

8 years ago · b40a135a7e
1 changed files with 3 additions and 1 deletions
--- a/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttClientImpl.java
+++ b/netty-mqtt/src/main/java/org/thingsboard/mqtt/MqttClientImpl.java
@ -390,7 +390,9 @@ final class MqttClientImpl implements MqttClient {
    }

    public void onSuccessfulReconnect() {
-        callback.onSuccessfulReconnect();
+        if (callback != null) {
+            callback.onSuccessfulReconnect();
+        }
    }