|
|
@ -375,6 +375,7 @@ public class QuartzSchedulerThread extends Thread { |
|
|
|
shell = qsRsrcs.getJobRunShellFactory().createJobRunShell(bndle); |
|
|
|
shell = qsRsrcs.getJobRunShellFactory().createJobRunShell(bndle); |
|
|
|
shell.initialize(qs); |
|
|
|
shell.initialize(qs); |
|
|
|
} catch (SchedulerException se) { |
|
|
|
} catch (SchedulerException se) { |
|
|
|
|
|
|
|
org.jboss.logging.Logger.getLogger(getClass()).error("---------error occur in job run shell initialize, jobKey:"+triggers.get(i).getJobKey(), se); |
|
|
|
qsRsrcs.getJobStore().triggeredJobComplete(triggers.get(i), bndle.getJobDetail(), CompletedExecutionInstruction.SET_ALL_JOB_TRIGGERS_ERROR); |
|
|
|
qsRsrcs.getJobStore().triggeredJobComplete(triggers.get(i), bndle.getJobDetail(), CompletedExecutionInstruction.SET_ALL_JOB_TRIGGERS_ERROR); |
|
|
|
continue; |
|
|
|
continue; |
|
|
|
} |
|
|
|
} |
|
|
@ -385,6 +386,7 @@ public class QuartzSchedulerThread extends Thread { |
|
|
|
// a thread pool being used concurrently - which the docs
|
|
|
|
// a thread pool being used concurrently - which the docs
|
|
|
|
// say not to do...
|
|
|
|
// say not to do...
|
|
|
|
getLog().error("ThreadPool.runInThread() return false!"); |
|
|
|
getLog().error("ThreadPool.runInThread() return false!"); |
|
|
|
|
|
|
|
org.jboss.logging.Logger.getLogger(getClass()).error("---------error occur in job shell run in thread, jobKey:"+triggers.get(i).getJobKey()); |
|
|
|
qsRsrcs.getJobStore().triggeredJobComplete(triggers.get(i), bndle.getJobDetail(), CompletedExecutionInstruction.SET_ALL_JOB_TRIGGERS_ERROR); |
|
|
|
qsRsrcs.getJobStore().triggeredJobComplete(triggers.get(i), bndle.getJobDetail(), CompletedExecutionInstruction.SET_ALL_JOB_TRIGGERS_ERROR); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|