ctripcorp/zeus
1
1
Fork 0
mirror of https://github.com/ctripcorp/zeus.git synced 2024-11-11 09:46:31 +08:00
Code Issues Projects Releases Packages Wiki Activity

fix

Browse source
This commit is contained in:
fanqq 2015-09-11 17:11:34 +08:00
parent afd2076463
commit 7c41ebc93c
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/main/java/com/ctrip/zeus/executor/impl/TaskWorkerImpl.java
View file

@ -9,7 +9,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import javax.annotation.Resource;
/**
* Created by fanqq on 2015/7/31.
@ -22,6 +22,7 @@ public class TaskWorkerImpl implements TaskWorker {
@Resource
TaskExecutor taskExecutor;
Logger logger = LoggerFactory.getLogger(this.getClass());
private static int initFailCount = 0;
@Override
public void execute() {
try {
@ -42,7 +43,11 @@ public class TaskWorkerImpl implements TaskWorker {
Slb slb = slbRepository.getBySlbServer(S.getIp());
if (slb != null && slb.getId()!=null){
workerSlbId = slb.getId();
initFailCount = 0;
}else{
if (++initFailCount > 3){
workerSlbId = null;
}
logger.error("Can Not Found Slb by Local Ip. TaskExecutor is not working!");
}
}