src/main/java/com/zy/core/thread/ShuttleThread.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/zy/core/thread/ShuttleThread.java
@@ -178,7 +178,7 @@ if (shuttleProtocol.getErrorCode() != 0 && shuttleProtocol.getProtocolStatusType() == ShuttleProtocolStatusType.WORKING) { //出现错误 reset(shuttleProtocol.getTaskNo()); resetAndTryFix(shuttleProtocol.getTaskNo()); } if(shuttleProtocol.getProtocolStatusType() == ShuttleProtocolStatusType.FIXING @@ -950,7 +950,7 @@ /** * 复位并尝试修复错误 */ private boolean reset(Short wrkNo) { private boolean resetAndTryFix(Short wrkNo) { //读取redis数据 if (wrkNo == null) { return false;