lxy/zhub-client
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改：断线重连次数判断 bug

Browse Source
This commit is contained in:
梁显优 2023-03-06 21:51:51 +08:00
parent 1171304a04
commit 44c1cf9f0d
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/com/zdemo/zhub/ZHubClient.java
View File

@ -373,8 +373,13 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
}
return true;
} catch (Exception e) {
if (retry == 0 || i > 0) {
if (retry == 0 || i == 0) {
logger.log(Level.WARNING, String.format("ZHubClient[%s] %s Failed 初始化失败！", getGroupid(), retry == 0 ? "init" : "reconnection"), e);
try {
Thread.sleep(1000);
} catch (InterruptedException interruptedException) {
interruptedException.printStackTrace();
}
} else {
logger.log(Level.WARNING, String.format("ZHubClient[%s][%s] reconnection Failed！", getGroupid(), i + 1));
try {