From ad4e699bb64ef87acdc200ab5b6338a0dcecc95f Mon Sep 17 00:00:00 2001
From: AKurakin <akurakin@mfd.ru>
Date: Fri, 30 Jun 2023 11:08:20 +0300
Subject: [PATCH] =?UTF-8?q?clearing-service=20=D0=B2=D0=BE=D0=B7=D0=B2?=
 =?UTF-8?q?=D1=80=D0=B0=D1=89=D0=B5=D0=BD=D0=B8=D0=B5=20=D0=BE=D1=82=D0=B2?=
 =?UTF-8?q?=D0=B5=D1=82=D0=B0=20=D0=B2=20REQUEST=5FINFO=5FUPDATE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/ru/spcex/clearing/service/EventsReceiver.java  | 5 +++--
 .../ru/spcex/clearing/service/LauncherCommandReceiver.java   | 5 +++--
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/EventsReceiver.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/EventsReceiver.java
index 6e7647e5c..ef695401e 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/EventsReceiver.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/EventsReceiver.java
@@ -1,6 +1,7 @@
 package ru.spcex.clearing.service;
 
 import org.apache.kafka.clients.consumer.Consumer;
+import org.apache.kafka.clients.producer.Producer;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.InitializingBean;
@@ -39,7 +40,7 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
     private final BalanceRevise balanceRevise;
 
     @Autowired
-    public EventsReceiver(Consumer<String, Object> kafkaQueue,
+    public EventsReceiver(Consumer<String, Object> kafkaQueue, Producer<String, Object> kafkaResponseQueue,
                           ClearingService clearingService,
                           RegistryService registryService,
                           PrimaryAuctionBnSession primaryAuctionBnSession,
@@ -47,7 +48,7 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
                           PrimaryAuctionB0Session primaryAuctionB0Session, PrimaryAuctionT0Session primaryAuctionT0Session, IntermediateMkrSession intermediateMkrSession, FinalMkrSession finalMkrSession, ReturnDepositSession returnDepositSession, SessionManager sessionManager,
                           Sdf06Executor sdf06Executor,
                           BalanceRevise balanceRevise) {
-        super(kafkaQueue);
+        super(kafkaQueue, kafkaResponseQueue);
         this.clearingService = clearingService;
         this.registryService = registryService;
         this.primaryAuctionBnSession = primaryAuctionBnSession;
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/LauncherCommandReceiver.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/LauncherCommandReceiver.java
index 06d5aa4ef..850f33e89 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/LauncherCommandReceiver.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/LauncherCommandReceiver.java
@@ -1,6 +1,7 @@
 package ru.spcex.clearing.service;
 
 import org.apache.kafka.clients.consumer.Consumer;
+import org.apache.kafka.clients.producer.Producer;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.InitializingBean;
@@ -16,9 +17,9 @@ public class LauncherCommandReceiver extends QueueConsumer implements Initializi
 
     private final ClearingService clearingService;
     @Autowired
-    public LauncherCommandReceiver(Consumer<String, Object> kafkaQueue,
+    public LauncherCommandReceiver(Consumer<String, Object> kafkaQueue, Producer<String, Object> kafkaResponseQueue,
                                    ClearingService clearingService) {
-        super(kafkaQueue);
+        super(kafkaQueue, kafkaResponseQueue);
         this.clearingService = clearingService;
     }