treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-189 changed account balance timeout wait

Browse source
This commit is contained in:
ialbert 2023-02-09 12:09:47 +03:00
parent 52543344d4
commit 4f3f78f4ba
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java
View file

@ -37,6 +37,7 @@ import java.util.function.Supplier;
@Service @Service
public class Clearing { public class Clearing {
private final static Integer ACC_BALANCE_TIMEOUT = 5 * 60 * 1000;
private final Logger log = LoggerFactory.getLogger(getClass()); private final Logger log = LoggerFactory.getLogger(getClass());
private final Imdg<ExecutionDeposit> executionDepositImdg; private final Imdg<ExecutionDeposit> executionDepositImdg;
private final Imdg<LiabilitiesClaimsAssets> liabilitiesClaimsAssetsImdg; private final Imdg<LiabilitiesClaimsAssets> liabilitiesClaimsAssetsImdg;
@ -180,7 +181,7 @@ public class Clearing {
Long sentRequestId = kafka.sendRequestToQueue(Consts.BALANCE_ACCOUNT_UPDATE, request); Long sentRequestId = kafka.sendRequestToQueue(Consts.BALANCE_ACCOUNT_UPDATE, request);
log.trace("sent request to kafka, requestId: {}", sentRequestId); log.trace("sent request to kafka, requestId: {}", sentRequestId);
try { try {
wait(10000); wait(ACC_BALANCE_TIMEOUT);
//если на этом месте произошла ошибка - непонятно как обрабатывать //если на этом месте произошла ошибка - непонятно как обрабатывать
//т.к. этом может быть уже вторая часть сделки, для первой accountBalance уже был обновлен //т.к. этом может быть уже вторая часть сделки, для первой accountBalance уже был обновлен
//либо вне зависимости от того какая часть сделки, accountBalance на самом деле мог быть //либо вне зависимости от того какая часть сделки, accountBalance на самом деле мог быть