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