private void registerJobExecutionEventListener(Object bean) { if (bean instanceof AbstractJob && this.applicationContext.containsBean(BatchEventAutoConfiguration.JOB_EXECUTION_EVENTS_LISTENER)) { JobExecutionListener jobExecutionEventsListener = (JobExecutionListener) this.applicationContext.getBean( BatchEventAutoConfiguration.JOB_EXECUTION_EVENTS_LISTENER); AbstractJob job = (AbstractJob) bean; job.registerJobExecutionListener( jobExecutionEventsListener); } }
@Bean public Job importUserJob(JobBuilderFactory jobs, Step s1, JobExecutionListener executionListener) { return jobs.get("importUserJob") .incrementer(new RunIdIncrementer()) .listener(executionListener) .flow(s1) .end() .build(); }
@Bean public Job writeStepJob(JobBuilderFactory jobs, Step stepOne, JobExecutionListener listener) { return jobs.get("writeStepJob") .incrementer(new RunIdIncrementer()) .listener(listener) .flow(stepOne) .end() .build(); }
@Bean public Job writeJsonFormatJob(JobBuilderFactory jobs, Step stepOne, JobExecutionListener listener) { return jobs.get("JsonWriter") .incrementer(new RunIdIncrementer()) .listener(listener) .flow(stepOne) .end() .build(); }
@Bean public Job importUserJob(JobBuilderFactory jobs, Step step1, Step step2, JobExecutionListener listener) { return jobs.get("importUserJob") .incrementer(new RunIdIncrementer()) .listener(listener) .flow(step1) .next(step2) .end() .build(); }
@Bean public JobExecutionListener listener() { return new JobCompletionNotificationListener(); }
@Bean public Job importUserJob(JobBuilderFactory jobs, Step s1, JobExecutionListener listener) { return jobs.get("importUserJob").incrementer(new RunIdIncrementer()).listener(listener).flow(s1).end().build(); }
@Bean public Job job(JobExecutionListener listener, Step stepProcess) { return jobs.get("simpleStringProcessorTask").incrementer(new RunIdIncrementer()).flow(stepProcess).end().listener(simpleJobLogger).build(); }
@Bean public Job job(JobExecutionListener listener,Step stepTasklet) { return jobs.get("HelloJob").listener(listener).start(stepTasklet()).build(); }
public void setJobListeners(List<JobExecutionListener> jobListeners) { this.jobListeners = jobListeners; }
@Override public void beforeJob(JobExecution jobExecution) { for(JobExecutionListener jobListener : jobListeners) { jobListener.beforeJob(jobExecution); } }
@Override public void afterJob(JobExecution jobExecution) { for(JobExecutionListener jobListener : jobListeners) { jobListener.afterJob(jobExecution); } }
@Bean @Lazy @ConditionalOnProperty(prefix = "spring.cloud.task.batch.events.job-execution", name = "enabled", havingValue = "true", matchIfMissing = true) public JobExecutionListener jobExecutionEventsListener() { return new EventEmittingJobExecutionListener(listenerChannels.jobExecutionEvents(),taskEventProperties.getJobExecutionOrder()); }
@Override public Set<JobExecutionListener> jobExecutionListeners() { Set<JobExecutionListener> listeners = new HashSet<JobExecutionListener>(); listeners.add(metricsListener()); return listeners; }
@Override public Set<JobExecutionListener> jobExecutionListeners() { Set<JobExecutionListener> listeners = new HashSet<JobExecutionListener>(); listeners.add(testListener()); return listeners; }
@Bean public JobExecutionListener jobLoggerListener() { return new JobLoggerListener(); }
/** * Returns a set of JobExecutionListeners that will be added to each Job. * May not return null. * @return Returns a set of JobExecutionListeners that will be added to each Job. May not return null. */ public Set<JobExecutionListener> jobExecutionListeners();