From 9147c6cf8723633750ad4e9393cef8d885e17187 Mon Sep 17 00:00:00 2001 From: etreschenkov Date: Fri, 28 Jun 2024 14:19:27 +0300 Subject: [PATCH] set requestId from gateway [1] --- .../clearing/account/service/TradingClearingRegistryService.java | 1 + 1 file changed, 1 insertion(+) 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); } }