修改日志打印

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

@@ -111,13 +111,13 @@ public class MqttDataConnector {
 
             @Override
             public void messageArrived(String topic, MqttMessage message) throws Exception {
-                logger.error("{}订阅丢失 connectionLost cause ---> {}"  ,topic,message.toString());
+                logger.error("{}接收到新消息 ---> {}"  ,topic,message.toString());
             }
 
             @Override
             public void deliveryComplete(IMqttDeliveryToken token) {
                 try {
-                    logger.error("{}订阅丢失 connectionLost cause ---> {}"  ,token.getMessage().toString());
+                    logger.error("{}消息已发送 ---> {}"  ,token.getMessage().toString());
                 } catch (MqttException e) {
                     e.printStackTrace();
                 }