From 4e0d1be6779dda15ca145ec777e7db532d570648 Mon Sep 17 00:00:00 2001 From: xuxueli <931591021@qq.com> Date: Sun, 30 Jul 2017 13:36:42 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BF=83=E8=B7=B3=E6=B3=A8=E5=86=8C=E5=92=8C?= =?UTF-8?q?=E7=BB=93=E6=9E=9C=E5=9B=9E=E8=B0=83=EF=BC=8C=E9=87=8D=E8=AF=95?= =?UTF-8?q?=E9=80=BB=E8=BE=91=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/xxl/job/core/executor/XxlJobExecutor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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