|
|
|
@ -1199,27 +1199,26 @@ public abstract class JobStoreSupport implements JobStore, Constants {
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (job == null) { |
|
|
|
|
try { |
|
|
|
|
try { |
|
|
|
|
if (job == null) { |
|
|
|
|
job = retrieveJob(conn, newTrigger.getJobKey()); |
|
|
|
|
if (job == null) { |
|
|
|
|
throw new JobPersistenceException("The job (" |
|
|
|
|
+ newTrigger.getJobKey() |
|
|
|
|
+ ") referenced by the trigger does not exist."); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (job.isConcurrentExectionDisallowed() && !recovering) { |
|
|
|
|
state = checkBlockedState(conn, job.getKey(), state); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
if (job == null) { |
|
|
|
|
throw new JobPersistenceException("The job (" |
|
|
|
|
+ newTrigger.getJobKey() |
|
|
|
|
+ ") referenced by the trigger does not exist."); |
|
|
|
|
} |
|
|
|
|
if (job.isConcurrentExectionDisallowed() && !recovering) { |
|
|
|
|
state = checkBlockedState(conn, job.getKey(), state); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (existingTrigger) { |
|
|
|
|
getDelegate().updateTrigger(conn, newTrigger, state, job); |
|
|
|
|
} else { |
|
|
|
|
getDelegate().insertTrigger(conn, newTrigger, state, job); |
|
|
|
|
} |
|
|
|
|
} catch (JobPersistenceException e) { |
|
|
|
|
getLog().error(e.getMessage()); |
|
|
|
|
if (existingTrigger) { |
|
|
|
|
getDelegate().updateTrigger(conn, newTrigger, state, job); |
|
|
|
|
} else { |
|
|
|
|
getDelegate().insertTrigger(conn, newTrigger, state, job); |
|
|
|
|
} |
|
|
|
|
} catch (JobPersistenceException e) { |
|
|
|
|
getLog().error(e.getMessage()); |
|
|
|
|
} |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
throw new JobPersistenceException("Couldn't store trigger '" + newTrigger.getKey() + "' for '" |
|
|
|
|