diff --git a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/TradingClearingRegistryService.java b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/TradingClearingRegistryService.java index 646decd21..7770a225c 100644 --- a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/TradingClearingRegistryService.java +++ b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/TradingClearingRegistryService.java @@ -522,6 +522,7 @@ public class TradingClearingRegistryService extends QueueConsumer implements Ini if (tkr.isPresent()) { SendTkrRequest sendTkrRequest = new SendTkrRequest(); sendTkrRequest.getTkrs().add(tkr.get()); + sendTkrRequest.setRequestId(req.getRequestId()); kafkaSender.sendRequestToQueue(Consts.ACCOUNTS_TO_GATEWAY, sendTkrRequest); } }