@ -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 ) ;
}
}