优化注册重试
This commit is contained in:
@@ -143,7 +143,7 @@ public class AgentDecoderHandler extends ChannelInboundHandlerAdapter {
|
||||
}
|
||||
byteBuf.release(); // 释放 ByteBuf 资源(重要!)
|
||||
} else {
|
||||
System.out.println("Unexpected message type: " + msg.getClass());
|
||||
AssertLog.error("Unexpected message type: " + msg.getClass());
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -781,7 +781,7 @@ public class BusinessTasks {
|
||||
boolean success = true;
|
||||
int activeConnect = client.getActiveConnections();
|
||||
AssertLog.info("注册重试定时任务执行 - 时间: {},activeConnect={}", LocalDateTime.now(), activeConnect);
|
||||
if(activeConnect == 0){
|
||||
if(activeConnect == 0 || count > 1){
|
||||
success = agentService.connection();
|
||||
}
|
||||
if(success){
|
||||
|
||||
Reference in New Issue
Block a user