pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/mqtt/MqttMessageListener.java
@@ -29,7 +29,7 @@ public void callback(MqttSubMsg subMsg) { DevStatusDealer.onLine(subMsg.deviceId, subMsg.protocol); DevStatusDealer.afterReceiveSubMessage(subMsg.deviceId); RtuLogDealer.log4Mqtt(subMsg.deviceId, "订阅消息 主题:" + subMsg.topic.longName() + " 元数据:" + subMsg.metaData); RtuLogDealer.log4Mqtt(subMsg.deviceId, "订阅消息 主题:" + subMsg.topic.longName() + " 原数据:" + subMsg.metaData); } @Override