| | |
| | | RtuLogNode logNode = new RtuLogNode(rtuAddr, content) ; |
| | | |
| | | ResourceUnit.getInstance().rtuLog(logNode); |
| | | |
| | | ///////////////////// |
| | | // 或者向消息中间件发消息 |
| | | //////////////////// |
| | | } |
| | | /** |
| | | * 记录Rtu日志 |
| | | * @param devId |
| | | * @param content |
| | | */ |
| | | public static void log4Mqtt(String devId, String content){ |
| | | if(devId == null || devId.trim().equals("")){ |
| | | log.error("严重错误,记录Mqtt设备日志时,设备地址未提供!") ; |
| | | return ; |
| | | } |
| | | if(content == null || content.equals("")){ |
| | | log.error("严重错误,记录Mqtt设备日志时,日志内容未提供!") ; |
| | | return ; |
| | | } |
| | | RtuLogNode logNode = new RtuLogNode(devId, content) ; |
| | | |
| | | ResourceUnit.getInstance().rtuLog(logNode); |
| | | } |
| | | |
| | | } |