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

FINERACT-2181: Added threadlocal context reset during parallel accrual processing

Browse Source
This commit is contained in:
Arnold Galovics
2025-03-26 13:24:32 +01:00
committed by Arnold Gálovics
parent 961e6d1aa6
commit 134b097a5e
1 changed files with 17 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fineract-provider/src/main/java/org/apache/fineract/portfolio/loanaccount/service/LoanAccrualsProcessingServiceImpl.java
+17 -13
View File
@@ -161,19 +161,23 @@ public class LoanAccrualsProcessingServiceImpl implements LoanAccrualsProcessing
loans.forEach(outerLoan -> {
loanTasks.add(taskExecutor.submit(() -> {
ThreadLocalContextUtil.init(context);
transactionTemplate.executeWithoutResult(status -> {
Loan loan = loanRepositoryWrapper.findOneWithNotFoundDetection(outerLoan.getId());
setSetHelpers(loan);
try {
log.debug("Adding accruals for loan '{}'", loan.getId());
addAccruals(loan, tillDate, false, false, true);
log.debug("Successfully processed loan: '{}' for accrual entries", loan.getId());
} catch (Exception e) {
log.error("Failed to add accrual for loan {}", loan.getId(), e);
throw new RuntimeException("Failed to add accrual for loan " + loan.getId(), e);
}
});
try {
ThreadLocalContextUtil.init(context);
transactionTemplate.executeWithoutResult(status -> {
Loan loan = loanRepositoryWrapper.findOneWithNotFoundDetection(outerLoan.getId());
setSetHelpers(loan);
try {
log.debug("Adding accruals for loan '{}'", loan.getId());
addAccruals(loan, tillDate, false, false, true);
log.debug("Successfully processed loan: '{}' for accrual entries", loan.getId());
} catch (Exception e) {
log.error("Failed to add accrual for loan {}", loan.getId(), e);
throw new RuntimeException("Failed to add accrual for loan " + loan.getId(), e);
}
});
} finally {
ThreadLocalContextUtil.reset();
}
}));
});