CBSNexora/cbsnexora-backend
4
0
Fork 0
Code Issues Pull Requests Actions 37 Packages Projects Releases Wiki Activity

FINERACT-1724: Made inline loan COB reader and processor job scoped to avoid state sharing

Browse Source
This commit is contained in:
Arnold Galovics
2023-09-04 15:50:35 +02:00
committed by Arnold Gálovics
parent 0eb2a44ff3
commit c1ef701908
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fineract-provider/src/main/java/org/apache/fineract/cob/loan/LoanInlineCOBConfig.java
+3
View File
@@ -30,6 +30,7 @@ import org.apache.fineract.portfolio.loanaccount.domain.Loan;
import org.apache.fineract.portfolio.loanaccount.domain.LoanRepository; import org.apache.fineract.portfolio.loanaccount.domain.LoanRepository;
import org.springframework.batch.core.Job; import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step; import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.JobScope;
import org.springframework.batch.core.job.builder.JobBuilder; import org.springframework.batch.core.job.builder.JobBuilder;
import org.springframework.batch.core.launch.support.RunIdIncrementer; import org.springframework.batch.core.launch.support.RunIdIncrementer;
import org.springframework.batch.core.listener.ExecutionContextPromotionListener; import org.springframework.batch.core.listener.ExecutionContextPromotionListener;
@@ -96,11 +97,13 @@ public class LoanInlineCOBConfig {
.build(); .build();
} }
@JobScope
@Bean @Bean
public InlineCOBLoanItemReader inlineCobWorkerItemReader() { public InlineCOBLoanItemReader inlineCobWorkerItemReader() {
return new InlineCOBLoanItemReader(loanRepository); return new InlineCOBLoanItemReader(loanRepository);
} }
@JobScope
@Bean @Bean
public InlineCOBLoanItemProcessor inlineCobWorkerItemProcessor() { public InlineCOBLoanItemProcessor inlineCobWorkerItemProcessor() {
return new InlineCOBLoanItemProcessor(cobBusinessStepService); return new InlineCOBLoanItemProcessor(cobBusinessStepService);