From 7e388909732cee1ae39b3a4180a325ff75883bda Mon Sep 17 00:00:00 2001 From: "xueli.xue" Date: Mon, 13 Mar 2017 15:20:57 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B3=9B=E5=9E=8B=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/xxl/job/core/biz/impl/ExecutorBizImpl.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/biz/impl/ExecutorBizImpl.java b/xxl-job-core/src/main/java/com/xxl/job/core/biz/impl/ExecutorBizImpl.java index 4d2f3b02..fd393245 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/biz/impl/ExecutorBizImpl.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/biz/impl/ExecutorBizImpl.java @@ -61,7 +61,7 @@ public class ExecutorBizImpl implements ExecutorBiz { // valid handler IJobHandler jobHandler = XxlJobExecutor.loadJobHandler(triggerParam.getExecutorHandler()); if (jobHandler==null) { - return new ReturnT(ReturnT.FAIL_CODE, "job handler for JobId=[" + triggerParam.getJobId() + "] not found."); + return new ReturnT(ReturnT.FAIL_CODE, "job handler for JobId=[" + triggerParam.getJobId() + "] not found."); } // valid exists job thread：change handler, need kill old thread @@ -83,7 +83,7 @@ public class ExecutorBizImpl implements ExecutorBiz { // valid glueloader if (!GlueFactory.isActive()) { - return new ReturnT(ReturnT.FAIL_CODE, "glueLoader for JobId=[" + triggerParam.getJobId() + "] not found."); + return new ReturnT(ReturnT.FAIL_CODE, "glueLoader for JobId=[" + triggerParam.getJobId() + "] not found."); } // valid exists job thread：change handler or glue timeout, need kill old thread @@ -104,7 +104,7 @@ public class ExecutorBizImpl implements ExecutorBiz { jobHandler = GlueFactory.getInstance().loadNewInstance(triggerParam.getJobId()); } catch (Exception e) { logger.error("", e); - return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); + return new ReturnT(ReturnT.FAIL_CODE, e.getMessage()); } jobThread = XxlJobExecutor.registJobThread(triggerParam.getJobId(), new GlueJobHandler(jobHandler, triggerParam.getGlueUpdatetime())); }