| | |
|---|
| | | public void rescheduleTimingTask(TimingTask task) throws SchedulerException { |
|---|
| | | TriggerKey triggerKey = new TriggerKey("trigger_" + task.getId()); |
|---|
| | | Trigger oldTrigger = scheduler.getTrigger(triggerKey); |
|---|
| | | if (oldTrigger == null) { |
|---|
| | | scheduleTimingTask(task); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | if (!(oldTrigger instanceof CronTrigger)) { |
|---|
| | | throw new SchedulerException("Existing trigger is not a CronTrigger"); |
|---|
| | | scheduler.unscheduleJob(triggerKey); |
|---|
| | | scheduleTimingTask(task); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | CronTrigger newTrigger = TriggerBuilder.newTrigger() |
|---|
