|
|
@ -982,18 +982,21 @@ public abstract class JobStoreSupport implements JobStore, Constants { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
for (TriggerKey triggerKey : misfiredTriggers) { |
|
|
|
for (TriggerKey triggerKey : misfiredTriggers) { |
|
|
|
|
|
|
|
try { |
|
|
|
|
|
|
|
OperableTrigger trig = |
|
|
|
|
|
|
|
retrieveTrigger(conn, triggerKey); |
|
|
|
|
|
|
|
|
|
|
|
OperableTrigger trig = |
|
|
|
if (trig == null) { |
|
|
|
retrieveTrigger(conn, triggerKey); |
|
|
|
continue; |
|
|
|
|
|
|
|
} |
|
|
|
if (trig == null) { |
|
|
|
|
|
|
|
continue; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
doUpdateOfMisfiredTrigger(conn, trig, false, STATE_WAITING, recovering); |
|
|
|
doUpdateOfMisfiredTrigger(conn, trig, false, STATE_WAITING, recovering); |
|
|
|
|
|
|
|
|
|
|
|
if (trig.getNextFireTime() != null && trig.getNextFireTime().getTime() < earliestNewTime) |
|
|
|
if (trig.getNextFireTime() != null && trig.getNextFireTime().getTime() < earliestNewTime) |
|
|
|
earliestNewTime = trig.getNextFireTime().getTime(); |
|
|
|
earliestNewTime = trig.getNextFireTime().getTime(); |
|
|
|
|
|
|
|
} catch (JobPersistenceException e) { |
|
|
|
|
|
|
|
getLog().error(e.getMessage()); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
return new RecoverMisfiredJobsResult( |
|
|
|
return new RecoverMisfiredJobsResult( |
|
|
|