Java 类org.springframework.batch.core.JobExecutionListener 实例源码

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 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 writeStepJob(JobBuilderFactory jobs, Step stepOne, JobExecutionListener listener) {
    return jobs.get("writeStepJob")
            .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);
    }
}

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();
}

@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();