diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/executor/XxlJobExecutor.java b/xxl-job-core/src/main/java/com/xxl/job/core/executor/XxlJobExecutor.java index dde5f14e..6dde1a94 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/executor/XxlJobExecutor.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/executor/XxlJobExecutor.java @@ -79,7 +79,7 @@ public class XxlJobExecutor implements ApplicationContextAware { } // init executor-server - initExecutorServer(); + initExecutorServer(port, ip, appName, accessToken); } public void destroy(){ // destory JobThreadRepository @@ -118,7 +118,7 @@ public class XxlJobExecutor implements ApplicationContextAware { // ---------------------------------- executor-server ------------------------------------ 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.setAccessToken(accessToken); serverFactory.start(port, ip, appName); // jetty + registry