org.quartz.Scheduler#deleteJob ( )源码实例Demo

下面列出了org.quartz.Scheduler#deleteJob ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： supplierShop 文件： ScheduleUtils.java

/**
 * 创建定时任务
 */
public static void createScheduleJob(Scheduler scheduler, SysJob job) throws SchedulerException, TaskException
{
    Class<? extends Job> jobClass = getQuartzJobClass(job);
    // 构建job信息
    Long jobId = job.getJobId();
    String jobGroup = job.getJobGroup();
    JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(getJobKey(jobId, jobGroup)).build();

    // 表达式调度构建器
    CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(job.getCronExpression());
    cronScheduleBuilder = handleCronScheduleMisfirePolicy(job, cronScheduleBuilder);

    // 按新的cronExpression表达式构建一个新的trigger
    CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(getTriggerKey(jobId, jobGroup))
            .withSchedule(cronScheduleBuilder).build();

    // 放入参数，运行时的方法可以获取
    jobDetail.getJobDataMap().put(ScheduleConstants.TASK_PROPERTIES, job);

    // 判断是否存在
    if (scheduler.checkExists(getJobKey(jobId, jobGroup)))
    {
        // 防止创建时存在数据问题 先移除，然后在执行创建操作
        scheduler.deleteJob(getJobKey(jobId, jobGroup));
    }

    scheduler.scheduleJob(jobDetail, trigger);

    // 暂停任务
    if (job.getStatus().equals(ScheduleConstants.Status.PAUSE.getValue()))
    {
        scheduler.pauseJob(ScheduleUtils.getJobKey(jobId, jobGroup));
    }
}

源代码2 项目： RuoYi-Vue 文件： ScheduleUtils.java

/**
 * 创建定时任务
 */
public static void createScheduleJob(Scheduler scheduler, SysJob job) throws SchedulerException, TaskException
{
    Class<? extends Job> jobClass = getQuartzJobClass(job);
    // 构建job信息
    Long jobId = job.getJobId();
    String jobGroup = job.getJobGroup();
    JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(getJobKey(jobId, jobGroup)).build();

    // 表达式调度构建器
    CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(job.getCronExpression());
    cronScheduleBuilder = handleCronScheduleMisfirePolicy(job, cronScheduleBuilder);

    // 按新的cronExpression表达式构建一个新的trigger
    CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(getTriggerKey(jobId, jobGroup))
            .withSchedule(cronScheduleBuilder).build();

    // 放入参数，运行时的方法可以获取
    jobDetail.getJobDataMap().put(ScheduleConstants.TASK_PROPERTIES, job);

    // 判断是否存在
    if (scheduler.checkExists(getJobKey(jobId, jobGroup)))
    {
        // 防止创建时存在数据问题 先移除，然后在执行创建操作
        scheduler.deleteJob(getJobKey(jobId, jobGroup));
    }

    scheduler.scheduleJob(jobDetail, trigger);

    // 暂停任务
    if (job.getStatus().equals(ScheduleConstants.Status.PAUSE.getValue()))
    {
        scheduler.pauseJob(ScheduleUtils.getJobKey(jobId, jobGroup));
    }
}

源代码3 项目： ruoyiplus 文件： ScheduleUtils.java

/**
 * 删除定时任务
 */
public static void deleteScheduleJob(Scheduler scheduler, Long jobId)
{
    try
    {
        scheduler.deleteJob(getJobKey(jobId));
    }
    catch (SchedulerException e)
    {
        log.error("deleteScheduleJob 异常：", e);
    }
}

源代码4 项目： LuckyFrameWeb 文件： ScheduleUtils.java

/**
 * 删除定时任务
 */
public static void deleteScheduleJob(Scheduler scheduler, Long jobId)
{
    try
    {
        scheduler.deleteJob(getJobKey(jobId));
    }
    catch (SchedulerException e)
    {
        log.error("deleteScheduleJob 异常：", e);
    }
}

源代码5 项目： quartz-web 文件： QuartzUtils.java

/**
 * 删除Job和下面所有Trigger
 * @param jobDetail
 * @param scheduler
 * @throws SchedulerException
 */
public static void removeJob(JobDetail jobDetail, Scheduler scheduler) throws SchedulerException {
    // 暂停
    pauseJob(jobDetail, scheduler);
    // 移除
    scheduler.deleteJob(jobDetail.getKey());
}

源代码6 项目： griffin 文件： BatchJobOperatorImpl.java

public void deleteJob(String group, String name) throws SchedulerException {
    Scheduler scheduler = factory.getScheduler();
    JobKey jobKey = new JobKey(name, group);
    if (!scheduler.checkExists(jobKey)) {
        LOGGER.info("Job({},{}) does not exist.", jobKey.getGroup(), jobKey
            .getName());
        return;
    }
    scheduler.deleteJob(jobKey);

}

源代码7 项目： SuitAgent 文件： SchedulerUtil.java

/**
 * 执行计划任务
 * @param job
 * @param trigger
 * @return
 * @throws SchedulerException
 */
public static ScheduleJobResult executeScheduleJob(JobDetail job, Trigger trigger) throws SchedulerException {
    ScheduleJobResult scheduleJobResult = new ScheduleJobResult();
    //判断是否满足计划任务的创建条件
    if(job.getKey() == null || trigger.getKey() == null || job.getJobDataMap() == null){
        scheduleJobResult.setScheduleJobStatus(ScheduleJobStatus.FAILED);
        //不满足计划任务的创建条件，返回scheduleJobResult值类
        return scheduleJobResult;
    }
    scheduleJobResult.setJobDetail(job);
    scheduleJobResult.setTrigger(trigger);
    //开始分配计划任务
    Scheduler scheduler  = SchedulerFactory.getScheduler();
    //开始判断是否存在相同的计划任务
    if(scheduler.checkExists(job.getKey())){
        log.info("存在相同的计划任务:{}",job.getKey());
        scheduler.deleteJob(job.getKey());
        scheduleJobResult.setJobKey(job.getKey());
        scheduleJobResult.setTriggerKey(trigger.getKey());
        scheduleJobResult.setScheduleJobStatus(ScheduleJobStatus.ISEXIST);
        scheduler.scheduleJob(job,trigger);
        scheduler.start();
    }else{
        scheduler.scheduleJob(job,trigger);
        scheduler.start();
        scheduleJobResult.setJobKey(job.getKey());
        scheduleJobResult.setTriggerKey(trigger.getKey());
        scheduleJobResult.setScheduleJobStatus(ScheduleJobStatus.SUCCESS);
    }
    //计划任务分配成功
    return scheduleJobResult;
}

源代码8 项目： kafka-eagle 文件： QuartzManagerUtils.java

/** Remove job. */
public static void removeJob(String jobName) {
	try {
		Scheduler sched = schedulerFactory.getScheduler();
		TriggerKey triggerKey = TriggerKey.triggerKey("ke_trigger_name_" + new Date().getTime(), "ke_trigger_group_" + new Date().getTime());
		sched.pauseTrigger(triggerKey);
		sched.unscheduleJob(triggerKey);
		sched.deleteJob(JobKey.jobKey(jobName, KE_JOB_GROUP_NAME));
	} catch (Exception e) {
		throw new RuntimeException(e);
	}
}

源代码9 项目： Knowage-Server 文件： SchedulerServiceSupplier.java

/**
 * Delete job.
 * 
 * @param jobName the job name
 * @param jobGroupName the job group name
 * 
 * @return the string
 */
public   String deleteJob(String jobName, String jobGroupName) {
	StringBuffer servreponse = new StringBuffer();
	try {
		Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); 
		servreponse.append("<EXECUTION_OUTCOME ");
		scheduler.deleteJob(jobName, jobGroupName);
		servreponse.append("outcome=\"perform\"/>");
	} catch (SchedulerException e) {
		SpagoBITracer.critical(SpagoBIConstants.NAME_MODULE, this.getClass().getName(), "deleteJob", 
				"Error while deleting job", e);
		servreponse.append("outcome=\"fault\"/>");
	}	
	return servreponse.toString();
}

源代码10 项目： OpenFalcon-SuitAgent 文件： SchedulerUtil.java

/**
 * 执行计划任务
 * @param job
 * @param trigger
 * @return
 * @throws SchedulerException
 */
public static ScheduleJobResult executeScheduleJob(JobDetail job, Trigger trigger) throws SchedulerException {
    ScheduleJobResult scheduleJobResult = new ScheduleJobResult();
    //判断是否满足计划任务的创建条件
    if(job.getKey() == null || trigger.getKey() == null || job.getJobDataMap() == null){
        scheduleJobResult.setScheduleJobStatus(ScheduleJobStatus.FAILED);
        //不满足计划任务的创建条件，返回scheduleJobResult值类
        return scheduleJobResult;
    }
    scheduleJobResult.setJobDetail(job);
    scheduleJobResult.setTrigger(trigger);
    //开始分配计划任务
    Scheduler scheduler  = SchedulerFactory.getScheduler();
    //开始判断是否存在相同的计划任务
    if(scheduler.checkExists(job.getKey())){
        log.info("存在相同的计划任务:{}",job.getKey());
        scheduler.deleteJob(job.getKey());
        scheduleJobResult.setJobKey(job.getKey());
        scheduleJobResult.setTriggerKey(trigger.getKey());
        scheduleJobResult.setScheduleJobStatus(ScheduleJobStatus.ISEXIST);
        scheduler.scheduleJob(job,trigger);
        scheduler.start();
    }else{
        scheduler.scheduleJob(job,trigger);
        scheduler.start();
        scheduleJobResult.setJobKey(job.getKey());
        scheduleJobResult.setTriggerKey(trigger.getKey());
        scheduleJobResult.setScheduleJobStatus(ScheduleJobStatus.SUCCESS);
    }
    //计划任务分配成功
    return scheduleJobResult;
}

源代码11 项目： fixflow 文件： TaskInstanceEntity.java

public TokenEntity removeTimeOutTask() {

		if (getNode().getBoundaryEventRefs().size() > 0) {

			TokenEntity tokenEntity = this.getToken();
			String parentTokenId = tokenEntity.getParent().getId();
			try {
				Scheduler scheduler = Context.getProcessEngineConfiguration().getSchedulerFactory().getScheduler();

				Map<String, TokenEntity> tokenBrothers = tokenEntity.getParent().getChildren();

				int colseTokenBrothersNum = 0;

				for (String tokenBrotherKey : tokenBrothers.keySet()) {

					if (!tokenBrotherKey.equals(tokenEntity.getId())) {

						scheduler.deleteJob(JobKey.jobKey(tokenBrothers.get(tokenBrotherKey).getId(), "FixTimeOutTask_" + parentTokenId));
						tokenBrothers.get(tokenBrotherKey).end();
						colseTokenBrothersNum = colseTokenBrothersNum + 1;
						break;

					}
				}

				if (colseTokenBrothersNum == (tokenBrothers.keySet().size() - 1)) {
					tokenEntity.getParent().terminationChildToken();
					return tokenEntity.getParent();
				}

			} catch (SchedulerException e) {
				e.printStackTrace();
				throw new FixFlowException("流程在离开节点 " + this.getId() + " 的时候发生错误! 错误信息: " + e.toString(), e);
			}

		}

		return null;
	}

源代码12 项目： openhab1-addons 文件： FHTBinding.java

private void unscheduleJob(JobKey jobKey) {
    if (jobKey == null) {
        return;
    }
    try {
        Scheduler sched = StdSchedulerFactory.getDefaultScheduler();
        sched.deleteJob(jobKey);
    } catch (SchedulerException e) {
        logger.error("Error while unscheduling time update job", e);
    }

}

源代码13 项目： openhab1-addons 文件： CallMonitor.java

/**
 * Cancel the reconnect job.
 */
public void shutdownReconnectJob() {
    Scheduler sched = null;
    try {
        sched = StdSchedulerFactory.getDefaultScheduler();
        JobKey jobKey = jobKey("Reconnect", "FritzBox");
        if (sched.checkExists(jobKey)) {
            logger.debug("Found reconnection job. Shutting down...");
            sched.deleteJob(jobKey);
        }

    } catch (SchedulerException e) {
        logger.warn("Error shutting down reconnect job: {}", e.getLocalizedMessage());
    }
}

源代码14 项目： quartz-web 文件： QuartzUtils.java

public static void removeJob(String jobName, String jobGroup, Scheduler scheduler) throws SchedulerException {
    // 暂停
    pauseJob(jobName, jobGroup, scheduler);
    scheduler.deleteJob(getJobKey(jobName, jobGroup));
}

源代码15 项目： spring-cloud-shop 文件： JobTrigger.java

/**
 * 删除定时任务
 *
 * @param scheduler scheduler
 * @param jobName   jobName
 * @param jobGroup  jobGroup
 */
public static void deleteJob(Scheduler scheduler, String jobName, String jobGroup) throws SchedulerException {
    log.info("删除定时任务 jobName = {}, jobGroup = {}", jobName, jobGroup);
    scheduler.deleteJob(getJobKey(jobName, jobGroup));
}

源代码16 项目： frameworkAggregate 文件： ScheduleJobService.java

/**
 * 删除一个job
 * 
 * @param scheduleJob
 * @throws SchedulerException
 */
public void deleteJob(ScheduleJob scheduleJob) throws SchedulerException {
	Scheduler scheduler = schedulerFactoryBean.getScheduler();
	JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());
	scheduler.deleteJob(jobKey);
}