adamsaghy commented on code in PR #2569:
URL: https://github.com/apache/fineract/pull/2569#discussion_r964621188
##########
fineract-provider/src/main/java/org/apache/fineract/cob/loan/LoanCOBWorkerConfiguration.java:
##########
@@ -57,19 +60,42 @@ public class LoanCOBWorkerConfiguration {
private QueueChannel inboundRequests;
@Autowired
private COBBusinessStepService cobBusinessStepService;
+ @Autowired
+ private AppUserRepositoryWrapper userRepository;
- @Bean(name = "Loan COB worker")
- public Step loanCOBWorkerStep() {
+ @Bean
+ public Step loanBusinessStep() {
return stepBuilderFactory.get("Loan COB
worker").inputChannel(inboundRequests)
.<Loan,
Loan>chunk(cobPropertyService.getChunkSize(JobName.LOAN_COB.name())).reader(itemReader(null))
.processor(itemProcessor()).writer(itemWriter()).build();
}
+ @Bean(name = "Loan COB worker")
+ public Step loanCOBWorkerStep() {
+ return stepBuilderFactory.get("Loan COB worker -
Step").inputChannel(inboundRequests).flow(flow()).build();
+ }
+
@Bean
public Job loanCOBWorkerJob() {
return jobBuilderFactory.get("Loan COB
worker").start(loanCOBWorkerStep()).incrementer(new RunIdIncrementer()).build();
}
+ @Bean
+ public Flow flow() {
+ return new
FlowBuilder<Flow>("cobFlow").start(initialisationStep()).next(loanBusinessStep()).next(loanBusinessStep()).build();
Review Comment:
Duplicate ".next(loanBusinessStep())". Please remove one of them
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
