Loading readme.md 0 → 100644 +3 −0 Original line number Diff line number Diff line # README This project was created from the tutorial at https://www.youtube.com/watch?v=jilqHdnoDRM&t=1769s. src/main/java/com/chrrreeeeesss/springbatchtutorial/BatchJobCompletedListener.java +3 −1 Original line number Diff line number Diff line Loading @@ -3,17 +3,19 @@ package com.chrrreeeeesss.springbatchtutorial; import org.springframework.batch.core.BatchStatus; import org.springframework.batch.core.job.JobExecution; import org.springframework.batch.core.listener.JobExecutionListener; import org.springframework.stereotype.Component; import java.io.IOException; import java.nio.file.Files; import java.nio.file.Paths; import java.util.stream.Stream; @Component public class BatchJobCompletedListener implements JobExecutionListener { @Override public void afterJob(JobExecution jobExecution) { String filePath = "masked-data.csv"; String filePath = "src/main/resources/masked-data.csv"; if (jobExecution.getStatus() == BatchStatus.COMPLETED) { try (Stream<String> stream = Files.lines(Paths.get(filePath))) { stream.forEach(System.out::println); Loading src/main/java/com/chrrreeeeesss/springbatchtutorial/SpringBatchTutorialApplication.java +2 −1 Original line number Diff line number Diff line Loading @@ -52,9 +52,10 @@ public class SpringBatchTutorialApplication { } @Bean protected Job maskingJob(JobRepository jobRepository, Step maskingStep) { protected Job maskingJob(JobRepository jobRepository, Step maskingStep, BatchJobCompletedListener jobCompletedListener) { return new JobBuilder("masking-job", jobRepository) .start(maskingStep) .listener(jobCompletedListener) .build(); } Loading Loading
readme.md 0 → 100644 +3 −0 Original line number Diff line number Diff line # README This project was created from the tutorial at https://www.youtube.com/watch?v=jilqHdnoDRM&t=1769s.
src/main/java/com/chrrreeeeesss/springbatchtutorial/BatchJobCompletedListener.java +3 −1 Original line number Diff line number Diff line Loading @@ -3,17 +3,19 @@ package com.chrrreeeeesss.springbatchtutorial; import org.springframework.batch.core.BatchStatus; import org.springframework.batch.core.job.JobExecution; import org.springframework.batch.core.listener.JobExecutionListener; import org.springframework.stereotype.Component; import java.io.IOException; import java.nio.file.Files; import java.nio.file.Paths; import java.util.stream.Stream; @Component public class BatchJobCompletedListener implements JobExecutionListener { @Override public void afterJob(JobExecution jobExecution) { String filePath = "masked-data.csv"; String filePath = "src/main/resources/masked-data.csv"; if (jobExecution.getStatus() == BatchStatus.COMPLETED) { try (Stream<String> stream = Files.lines(Paths.get(filePath))) { stream.forEach(System.out::println); Loading
src/main/java/com/chrrreeeeesss/springbatchtutorial/SpringBatchTutorialApplication.java +2 −1 Original line number Diff line number Diff line Loading @@ -52,9 +52,10 @@ public class SpringBatchTutorialApplication { } @Bean protected Job maskingJob(JobRepository jobRepository, Step maskingStep) { protected Job maskingJob(JobRepository jobRepository, Step maskingStep, BatchJobCompletedListener jobCompletedListener) { return new JobBuilder("masking-job", jobRepository) .start(maskingStep) .listener(jobCompletedListener) .build(); } Loading