提交 564f2bd9 编写于 作者: O o2sword

集群成员存活刷新修改:1、每个集群成员都需要刷新而不只是主节点;2、集群成员存活校验有效时间改为1分钟,原为90秒

上级 138544c0
...@@ -20,7 +20,8 @@ public class CenterQueue extends AbstractQueue<CenterQueueBody> { ...@@ -20,7 +20,8 @@ public class CenterQueue extends AbstractQueue<CenterQueueBody> {
private static Logger logger = LoggerFactory.getLogger(CenterQueue.class); private static Logger logger = LoggerFactory.getLogger(CenterQueue.class);
public static final int REFRESHAPPLICATIONSINTERVAL = 45; //public static final int REFRESHAPPLICATIONSINTERVAL = 45;
public static final int REFRESHAPPLICATIONSINTERVAL = 30;
protected void execute(CenterQueueBody body) throws Exception { protected void execute(CenterQueueBody body) throws Exception {
......
...@@ -15,10 +15,8 @@ public class RefreshApplications extends BaseAction { ...@@ -15,10 +15,8 @@ public class RefreshApplications extends BaseAction {
@Override @Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
try { try {
if (pirmaryCenter()) { CenterQueueRefreshBody body = new CenterQueueRefreshBody();
CenterQueueRefreshBody body = new CenterQueueRefreshBody(); ThisApplication.centerQueue.send(body);
ThisApplication.centerQueue.send(body);
}
} catch (Exception e) { } catch (Exception e) {
logger.error(e); logger.error(e);
throw new JobExecutionException(e); throw new JobExecutionException(e);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册