eventbus and im 添加log打印。

BaseModule/src/main/java/com/xscm/moduleutil/service/MqttConnect.java

@@ -98,7 +98,7 @@ public class MqttConnect {
                     handler.postDelayed(new Runnable() {
                         @Override
                         public void run() {
-                            Log.e(Tag,"开始重连。。。");
+                            LogUtils.e(Tag,"开始重连。。。");
                             mqttClient();
                         }
                     },3000);
@@ -112,7 +112,7 @@ public class MqttConnect {
      * @param msg
      */
     private void uiTip(String msg){
-        Log.d(Tag,msg);
+        LogUtils.d(Tag,msg);
         handler.post(new Runnable() {
             @Override
             public void run() {
@@ -150,11 +150,11 @@ public class MqttConnect {
                 mqttClient.disconnect();
                 mqttClient = null;
             } catch (MqttException e) {
-                Log.e(Tag,"关闭MQTT连接报错："+e.getMessage());
+                LogUtils.e(Tag,"关闭MQTT连接报错："+e.getMessage());
 //                ToastUtils.show("关闭MQTT连接报错");
             }
         }else {
-            Log.d(Tag,"Mqtt已关闭");
+            LogUtils.d(Tag,"Mqtt已关闭");
         }
     }
 
@@ -194,7 +194,7 @@ public class MqttConnect {
         try {
             mqttClient.subscribe(topic);
         } catch (MqttException e) {
-            Log.e(Tag,"MQTT主题订阅失败：" + e.getMessage());
+            LogUtils.e(Tag,"MQTT主题订阅失败：" + e.getMessage());
 //            uiTip("MQTT主题订阅失败");
         }
     }
@@ -212,7 +212,7 @@ public class MqttConnect {
         try {
             mqttClient.subscribe(topic, qos);
         }catch (MqttException e){
-            Log.e(Tag,"订阅主题失败："+e.getMessage());
+            LogUtils.e(Tag,"订阅主题失败："+e.getMessage());
         }
     }