|
|
|
|
|
|
61
|
// valid handler
|
61
|
// valid handler
|
|
62
|
IJobHandler jobHandler = XxlJobExecutor.loadJobHandler(triggerParam.getExecutorHandler());
|
62
|
IJobHandler jobHandler = XxlJobExecutor.loadJobHandler(triggerParam.getExecutorHandler());
|
|
63
|
if (jobHandler==null) {
|
63
|
if (jobHandler==null) {
|
|
64
|
- return new ReturnT(ReturnT.FAIL_CODE, "job handler for JobId=[" + triggerParam.getJobId() + "] not found.");
|
|
|
|
|
|
64
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE, "job handler for JobId=[" + triggerParam.getJobId() + "] not found.");
|
|
65
|
}
|
65
|
}
|
|
66
|
|
66
|
|
|
67
|
// valid exists job thread:change handler, need kill old thread
|
67
|
// valid exists job thread:change handler, need kill old thread
|
|
|
|
|
|
|
83
|
|
83
|
|
|
84
|
// valid glueloader
|
84
|
// valid glueloader
|
|
85
|
if (!GlueFactory.isActive()) {
|
85
|
if (!GlueFactory.isActive()) {
|
|
86
|
- return new ReturnT(ReturnT.FAIL_CODE, "glueLoader for JobId=[" + triggerParam.getJobId() + "] not found.");
|
|
|
|
|
|
86
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE, "glueLoader for JobId=[" + triggerParam.getJobId() + "] not found.");
|
|
87
|
}
|
87
|
}
|
|
88
|
|
88
|
|
|
89
|
// valid exists job thread:change handler or glue timeout, need kill old thread
|
89
|
// valid exists job thread:change handler or glue timeout, need kill old thread
|
|
|
|
|
|
|
104
|
jobHandler = GlueFactory.getInstance().loadNewInstance(triggerParam.getJobId());
|
104
|
jobHandler = GlueFactory.getInstance().loadNewInstance(triggerParam.getJobId());
|
|
105
|
} catch (Exception e) {
|
105
|
} catch (Exception e) {
|
|
106
|
logger.error("", e);
|
106
|
logger.error("", e);
|
|
107
|
- return new ReturnT(ReturnT.FAIL_CODE, e.getMessage());
|
|
|
|
|
|
107
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE, e.getMessage());
|
|
108
|
}
|
108
|
}
|
|
109
|
jobThread = XxlJobExecutor.registJobThread(triggerParam.getJobId(), new GlueJobHandler(jobHandler, triggerParam.getGlueUpdatetime()));
|
109
|
jobThread = XxlJobExecutor.registJobThread(triggerParam.getJobId(), new GlueJobHandler(jobHandler, triggerParam.getGlueUpdatetime()));
|
|
110
|
}
|
110
|
}
|