mqtt客户端掉线重连

app/src/main/java/com/emato/ich/message/ICHPublishClient.java

@@ -70,6 +70,8 @@ public class ICHPublishClient {
             @Override
             public void connectionLost(Throwable cause) {
                 Log.e(TAG, "connectionLost: cause: ", cause);
+                connect();
+                LoggingUtils.sendErrorLog("mqtt-publish客户端断线！", cause);
             }
 
             @Override

app/src/main/java/com/emato/ich/message/ICHSubscribeClient.java

@@ -68,6 +68,8 @@ public class ICHSubscribeClient {
             public void connectionLost(Throwable cause) {
                 // TODO 重连
                 Log.e(TAG, "connectionLost: cause: ", cause);
+                connect();
+                LoggingUtils.sendErrorLog("mqtt-subscribe客户端断线！", cause);
             }
 
             @Override