设备故障消息推送 log

device-api-service/src/main/java/com/xy/consumer/device/push/msg/DevicePushMsgConsumer.java

@@ -37,6 +37,7 @@ public class DevicePushMsgConsumer implements MqttConsumer {
 
     @Override
     public boolean message(String topic, String payload) {
+        log.info("-----设备故障消息推送-----:{}", payload);
         DeviceEventMsg deviceEventMsg = JSONUtil.toBean(payload, DeviceEventMsg.class);
         if (deviceEventMsg != null) {
             Long deviceId = deviceEventMsg.getDeviceId();