SingleThreadEventDrivenJob.groovy

@Bean
Job singleThreadEventDrivenJob(ItemReader reader, ItemProcessor processor,
                               ItemWriter writer, MetricRegistry metricRegistry,
                               HtmlReportJobExecutionListener htmlReportJobExecutionListener,
                               ScheduledReporter reporter) {
    def statsListener = JobStateMachine.idle(
            new StatsListener(metricRegistry, { reporter.report() })
    )
    jobBuilderFactory
            .get("single.thread.event.driven.job")
            .listener(JobListenerFactoryBean.getListener(statsListener))
            .listener(htmlReportJobExecutionListener)
            .start(
            stepBuilderFactory.get("step1")
                    .chunk(10)
                    .faultTolerant().skip(Throwable).skipLimit(Integer.MAX_VALUE).listener(statsListener as Object)
                    .reader(reader)
                    .processor(processor)
                    .writer(writer)
                    .listener(statsListener as Object)
                    .build()
    ).build()
}