|
@@ -230,7 +230,7 @@ public final class XxlJobDynamicScheduler {
|
230
|
230
|
// 5、schedule job
|
231
|
231
|
Date date = scheduler.scheduleJob(jobDetail, cronTrigger);
|
232
|
232
|
|
233
|
|
- logger.info(">>>>>>>>>>> addJob success, jobDetail:{}, cronTrigger:{}, date:{}", jobDetail, cronTrigger, date);
|
|
233
|
+ logger.info(">>>>>>>>>>> addJob success(quartz), jobDetail:{}, cronTrigger:{}, date:{}", jobDetail, cronTrigger, date);
|
234
|
234
|
return true;
|
235
|
235
|
}
|
236
|
236
|
|
|
@@ -245,13 +245,15 @@ public final class XxlJobDynamicScheduler {
|
245
|
245
|
*/
|
246
|
246
|
public static boolean removeJob(String jobName, String jobGroup) throws SchedulerException {
|
247
|
247
|
|
248
|
|
- TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);
|
|
248
|
+ JobKey jobKey = new JobKey(jobName, jobGroup);
|
|
249
|
+ scheduler.deleteJob(jobKey);
|
249
|
250
|
|
|
251
|
+ /*TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);
|
250
|
252
|
if (scheduler.checkExists(triggerKey)) {
|
251
|
253
|
scheduler.unscheduleJob(triggerKey); // trigger + job
|
252
|
|
- }
|
|
254
|
+ }*/
|
253
|
255
|
|
254
|
|
- logger.info(">>>>>>>>>>> removeJob success, triggerKey:{}", triggerKey);
|
|
256
|
+ logger.info(">>>>>>>>>>> removeJob success(quartz), triggerKey:{}", jobKey);
|
255
|
257
|
return true;
|
256
|
258
|
}
|
257
|
259
|
|