Merge remote-tracking branch 'origin/master'

src/main/java/com/care/mqtt/service/MqttMsgInstallService.java

@@ -65,6 +65,7 @@ public class MqttMsgInstallService {
             //logger.error("不是要处理的消息");
             return;
         }
+        logger.info("{}房屋配置信息返回,{}",topic,mqttMessageStr);
         Map msg = (Map) map.get("msg");
         if(msg == null) {
             logger.error("不是正确格式的消息");

src/main/java/com/care/mqtt/tool/MqttDataConnector.java

@@ -158,6 +158,7 @@ public class MqttDataConnector {
         //消费者断开连接后是否接受离线消息
         mqttMessage.setRetained(true);
         mqttClient.publish(publicLiveTopic,mqttMessage);
+        logger.info("topic:{} send  content {} ",publicLiveTopic,data);
         logger.info("topic:{} send  dataSize {}kb ",publicLiveTopic,data.length()/1024.0);
 
     }