@Bean(name="job2") public Job job2() { SimpleJob job = new SimpleJob(); job.setRestartable(false); return jobs .get("myJob2") .incrementer(new RunIdIncrementer()) .start(steps.get("step3").tasklet((stepContribution, chunkContext) -> { System.out.println("job2 step"); return RepeatStatus.FINISHED;}).build()) .build(); }
@Test public void testBatchExecutionListenerBeanPostProcessorWithJobNames() { List jobNames = new ArrayList<String>(3); jobNames.add("job1"); jobNames.add("job2"); jobNames.add("TESTOBJECT"); TaskBatchExecutionListenerBeanPostProcessor beanPostProcessor = beanPostProcessor(jobNames); SimpleJob testObject = new SimpleJob(); SimpleJob bean = (SimpleJob) beanPostProcessor. postProcessBeforeInitialization(testObject,"TESTOBJECT"); assertEquals(testObject,bean); }
@Test public void testBatchExecutionListenerBeanPostProcessorWithEmptyJobNames() { TaskBatchExecutionListenerBeanPostProcessor beanPostProcessor = beanPostProcessor(Collections.<String>emptyList()); SimpleJob testObject = new SimpleJob(); SimpleJob bean = (SimpleJob) beanPostProcessor. postProcessBeforeInitialization(testObject,"TESTOBJECT"); assertEquals(testObject,bean); }
protected SimpleJob createSimpleJob(String name, Step initialStep) { SimpleJob job = new SimpleJob(name); job.setJobRepository(jobRepository); job.addStep(initialStep); return job; }
@Override protected void executeInternal(JobExecutionContext context) throws JobExecutionException { TaskletStep ts = createTaskletStep("snapshotRun", snapshotBatchJobTasklet); SimpleJob job = createSimpleJob("snapshotBatchJob", ts); // by default, jobs are assumed to have been already run if the exact same // parameters are seen. Pass in the time to always be unique. Map<String, JobParameter> map = new HashMap<>(); map.put("executeTime", new JobParameter(System.currentTimeMillis())); runJob(job, context, map); }
@Override protected void executeInternal(JobExecutionContext context) throws JobExecutionException { TaskletStep ts = createTaskletStep("nightlyRun", nightlyReportBatchJobTasklet); SimpleJob job = createSimpleJob("nightlyReportBatchJob", ts); // by default, jobs are assumed to have been already run if the exact same // parameters are seen. Pass in the time to always be unique. Map<String, JobParameter> map = new HashMap<>(); map.put("executeTime", new JobParameter(System.currentTimeMillis())); runJob(job, context, map); }
@Override protected void executeInternal(JobExecutionContext context) throws JobExecutionException { TaskletStep ts = createTaskletStep("HourlyRun", HourlyReportBatchJobTasklet); SimpleJob job = createSimpleJob("HourlyReportBatchJob", ts); // by default, jobs are assumed to have been already run if the exact same // parameters are seen. Pass in the time to always be unique. Map<String, JobParameter> map = new HashMap<>(); map.put("executeTime", new JobParameter(System.currentTimeMillis())); runJob(job, context, map); }
@Override protected void executeInternal(JobExecutionContext context) throws JobExecutionException { TaskletStep ts = createTaskletStep("deleteSnapshotWindow", deleteSnapshotBatchJobTasklet); SimpleJob job = createSimpleJob("deleteSnapshotWindowBatchJob", ts); // by default, jobs are assumed to have been already run if the exact same // parameters are seen. Pass in the time to always be unique. Map<String, JobParameter> map = new HashMap<>(); map.put("executeTime", new JobParameter(System.currentTimeMillis())); map.put("snapshotWindowId", new JobParameter(context.getJobDetail().getJobDataMap().getLong("snapshotWindowId"))); runJob(job, context, map); }