心跳注册和结果回调,重试逻辑优化
This commit is contained in:
parent
09d8952448
commit
4e0d1be677
|
@ -79,7 +79,7 @@ public class XxlJobExecutor implements ApplicationContextAware {
|
||||||
}
|
}
|
||||||
|
|
||||||
// init executor-server
|
// init executor-server
|
||||||
initExecutorServer();
|
initExecutorServer(port, ip, appName, accessToken);
|
||||||
}
|
}
|
||||||
public void destroy(){
|
public void destroy(){
|
||||||
// destory JobThreadRepository
|
// destory JobThreadRepository
|
||||||
|
@ -118,7 +118,7 @@ public class XxlJobExecutor implements ApplicationContextAware {
|
||||||
|
|
||||||
// ---------------------------------- executor-server ------------------------------------
|
// ---------------------------------- executor-server ------------------------------------
|
||||||
private NetComServerFactory serverFactory = new NetComServerFactory();
|
private NetComServerFactory serverFactory = new NetComServerFactory();
|
||||||
private void initExecutorServer() throws Exception {
|
private void initExecutorServer(int port, String ip, String appName, String accessToken) throws Exception {
|
||||||
NetComServerFactory.putService(ExecutorBiz.class, new ExecutorBizImpl()); // rpc-service, base on jetty
|
NetComServerFactory.putService(ExecutorBiz.class, new ExecutorBizImpl()); // rpc-service, base on jetty
|
||||||
NetComServerFactory.setAccessToken(accessToken);
|
NetComServerFactory.setAccessToken(accessToken);
|
||||||
serverFactory.start(port, ip, appName); // jetty + registry
|
serverFactory.start(port, ip, appName); // jetty + registry
|
||||||
|
|
Loading…
Reference in New Issue