Spring Batch 6 で Listener を追加してログを出す

package com.netandfield.test.Listener;

import org.springframework.batch.core.job.JobExecution;

import org.springframework.batch.core.listener.JobExecutionListener;

import org.springframework.stereotype.Component;

import lombok.extern.slf4j.Slf4j;

@Component

@Slf4j

public class LogJobListener implements JobExecutionListener {

    @Override

    public void beforeJob(JobExecution jobExecution) {

        log.info("★Job started: " + jobExecution.getJobInstance().getJobName());

    }

    @Override

    public void afterJob(JobExecution jobExecution) {

        log.info("★Job finished: " + jobExecution.getJobInstance().getJobName() + " with status: " + jobExecution.getStatus());

    }

}

import org.springframework.batch.core.listener.JobExecutionListener;

import org.springframework.beans.factory.annotation.Autowired;

＜略＞

@Configuration

public class BatchConfig {

    private final JobRepository jobRepository;

    private final PlatformTransactionManager transactionManager;

    private final DataSource dataSource;

    @Autowired

    private JobExecutionListener jobListener;

＜略＞

    @Bean

    public Job exportJob() {

        return new JobBuilder("exportJob", jobRepository)

                .start(exportStep())

                .listener(jobListener) // JobExecutionListenerを追加

                .build();

    }

...

～ : Job: [SimpleJob: [name=exportJob]] launched with the following parameters: [{}]

～ : ★Job started: exportJob

～ : Executing step: [exportStep]

～ : Step: [exportStep] executed in 681ms

～ : ★Job finished: exportJob with status: COMPLETED

～ : Job: [SimpleJob: [name=exportJob]] completed with the following parameters: [{}] and the following status: [COMPLETED] in 698ms

...