Utilizo Spring Batch e implementé el oyente de escritor de elementos. Mi clase Item Writer Listener es algo como esto
@Component public class SomeItemWriterListener implements ItemWriteListener { @Override public void beforeWrite(List<Object> items) throws Exception { System.out.println("get here1"); } @Override public void afterWrite(List<Object> items) throws Exception { System.out.println("get here2"); } @Override public void onWriteError(List<Object> items, Exception ex) throws Exception { System.out.println("get here3"); } }Luego lo configuro en mi paso así usando Java Config
@Autowired private SomeItemWriterListener writerListener; @Bean public Step step(StepBuilderFactory stepBuilderFactory, @Qualifier("itemReader") ItemReader<SomeItem> reader) { return stepBuilderFactory.get("step").listener( writerListener).chunk( chunkSize).reader(reader).processor(processor).writer(writer).build(); }Pero, beforeWrite, afterWrite no se llama. Cuando agrego algún error onWriterError tampoco se llama. ¿Me perdí algo cuando configuré esto?
Está llamando al StepBuilderHelper.listener(Object) que, como puede ver, solo es para oyentes basados en anotaciones. Además de eso, está tratando de registrar el oyente en el nivel de paso, mientras que debería registrarlo en el nivel de fragmento.
@Bean public Step step(StepBuilderFactory stepBuilderFactory, @Qualifier("itemReader") ItemReader<SomeItem> reader) { return stepBuilderFactory.get("step") .chunk(chunkSize) .reader(reader) .processor(processor) .writer(writer) .listener(writerListener) .build(); } Esto llamará al método de listener(ItemWriteListener) (también hay un listener(Object) , es posible que necesite convertir a la interfaz ItemWriteListener para invocar el método correcto.