added condition to call scheduler's standby
This commit is contained in:
committed by
Vishwas Babu A J
parent
f34b54eddb
commit
111175df91
+3
@@ -195,6 +195,9 @@ public class JobRegisterServiceImpl implements JobRegisterService {
|
|||||||
JobDetail jobDetail = createJobDetail(scheduledJobDetails);
|
JobDetail jobDetail = createJobDetail(scheduledJobDetails);
|
||||||
Trigger trigger = createTrigger(scheduledJobDetails, jobDetail);
|
Trigger trigger = createTrigger(scheduledJobDetails, jobDetail);
|
||||||
Scheduler scheduler = getScheduler(scheduledJobDetails);
|
Scheduler scheduler = getScheduler(scheduledJobDetails);
|
||||||
|
if (!this.schedulerStatus.get(ThreadLocalContextUtil.getTenant().getId()) && !scheduler.isInStandbyMode()) {
|
||||||
|
scheduler.standby();
|
||||||
|
}
|
||||||
scheduler.scheduleJob(jobDetail, trigger);
|
scheduler.scheduleJob(jobDetail, trigger);
|
||||||
scheduledJobDetails.updateJobKey(getJobKeyAsString(jobDetail.getKey()));
|
scheduledJobDetails.updateJobKey(getJobKeyAsString(jobDetail.getKey()));
|
||||||
scheduledJobDetails.updateNextRunTime(trigger.getNextFireTime());
|
scheduledJobDetails.updateNextRunTime(trigger.getNextFireTime());
|
||||||
|
|||||||
Reference in New Issue
Block a user