Приложение SpringBatch не работает - PullRequest
0 голосов
/ 19 июня 2019

Я пытаюсь создать задание Spring Batch с приведенной ниже конфигурацией в проекте SpringBoot.Сборка Maven прошла успешно, но приложение не может проверить конечную точку, определенную для Spring Batch.Отдельный основной класс имеет аннотацию @SpringBootApplication.У кого-нибудь есть идеи, почему мое приложение springBoot не запускается в моем localBox

PFB, файл конфигурации для springBatch

@Log4j2
@Configuration
@EnableBatchProcessing
public class BatchConfig {

    @Autowired
    public JobBuilderFactory jobBuilderFactory;

    @Autowired
    public StepBuilderFactory stepBuilderFactory;


    @Bean
    public Job batchConfig Job() {
        return this.jobBuilderFactory.get("batchConfigJob")
            .start(a())
            .next(b())
            .next(c())
            .next(d())
            .build();
    }

    @Bean
    public Step a() {
        System.out.println("BatchConfig.a");
        return this.stepBuilderFactory.get("step1")
            .<BIE<c>, BIEP.BIEB>chunk(0)
            .reader(new BlockInventoryReader())
            .processor(new BatchBIEP())
            .writer(new BlockInventoryWriter())
            .build();
    }

    @Bean
    public Step b() {
        System.out.println("BatchConfig.b");
        return this.stepBuilderFactory.get("step2")
            .<BIEP.BIEB, BIEP.BIEB>chunk(0)
            .reader(new BkReader())// Need to implement
            .processor(new BKProcess())
            .writer(new BKWriter())
            .build();
    }

    @Bean
    public Step c() {
        System.out.println("BatchConfig.c");
        return this.stepBuilderFactory.get("step3")
            .<BIEP.BIEB, List<BIEc>>chunk(0)
            .reader(new cReader())//need to implement
            .processor(new cProcessor())
            .writer(new cWriter())
            .build();
    }

    @Bean
    public Step d() {
        System.out.println("BatchConfig.d");
        return this.stepBuilderFactory.get("step4")
            .<List<BIEc>, List<BIEc>>chunk(0)
            .reader(new SendcReader())
            .processor(new SendcProcessor())
            .writer(new SendcWriter())
            .build();

    }


    @BeforeJob
    public void beforeJob(JobExecution jobExecution) {
        System.out.println("BatchConfig.beforeJob");
    }

    @AfterJob
    public void afterJob(JobExecution jobExecution) {
        System.out.println("BatchConfig.afterJob");
        System.out.println("jobExecution = [" + jobExecution + "]");
        if (jobExecution.getStatus() == BatchStatus.COMPLETED) {
            log.info("Job Execution Completed : " + jobExecution.getStatus());
        } else if (jobExecution.getStatus() == BatchStatus.FAILED) {
            log.info("Job Execution Failed : " + jobExecution.getStatus());
        }
    }

}
...