| | |
| | | * @param propertiesStream 配置文件流 |
| | | * @return |
| | | */ |
| | | public static void start(InputStream propertiesStream) throws SchedulerException { |
| | | public static void start(InputStream propertiesStream){ |
| | | if(null == scheduler){ |
| | | scheduler = SchedulerUtil.getScheduler(propertiesStream); |
| | | } |
| | | scheduler.start(); |
| | | log.info(QuartzEnum.SCHEDULER_START_SUCCESS.getValue()); |
| | | try { |
| | | scheduler.start(); |
| | | log.info(QuartzEnum.SCHEDULER_START_SUCCESS.getValue()); |
| | | } catch (SchedulerException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | |
| | | |
| | |
| | | private static JobDetail getJobDetail(Job job, String job_name, String group_name, JobDataMap jobDataMap){ |
| | | JobDetail jobDetail = JobBuilder.newJob(job.getClass()) |
| | | .withIdentity(job_name, group_name) |
| | | .usingJobData(jobDataMap) |
| | | .setJobData(jobDataMap) |
| | | .build(); |
| | | return jobDetail; |
| | | } |