src/main/java/com/zy/core/thread/impl/NyShuttleThread.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/zy/core/thread/impl/NyShuttleThread.java
@@ -743,12 +743,21 @@ return false; } if (this.shuttleProtocol.getMode() == 0) { return true; } if (!this.shuttleProtocol.getErrorCode().equals("0")) { return true; } InnerSuhttleExtend extend = (InnerSuhttleExtend) this.shuttleProtocol.getExtend(); boolean res = this.shuttleProtocol.getMode() == 0 || !this.shuttleProtocol.getErrorCode().equals("0") || extend.getSuspendState() == 1 ; return res; if (extend.getSuspendState() == 1) { return true; } return false; } @Override