From 2d7bfae8a0812480cd6ad1c0677d116fb540f267 Mon Sep 17 00:00:00 2001
From: AKurakin <akurakin@mfd.ru>
Date: Wed, 24 May 2023 18:59:12 +0300
Subject: [PATCH] .

---
 .../exchangers/BiDirectionQueueExchanger.java |  2 ++
 .../services/AbstractExporterService.java     |  4 +--
 .../services/AbstractExporterServiceTest.java | 27 +++++++++++++++++++
 3 files changed, 30 insertions(+), 3 deletions(-)
 create mode 100644 clearing-parent/lim-exporter/src/test/java/ru/spcex/clearing/lim/exporter/services/AbstractExporterServiceTest.java

diff --git a/clearing-parent/clearing-validation/src/main/java/ru/spcex/clearing/util/services/exchangers/BiDirectionQueueExchanger.java b/clearing-parent/clearing-validation/src/main/java/ru/spcex/clearing/util/services/exchangers/BiDirectionQueueExchanger.java
index 0d8ec8a1d..eaec45cc3 100644
--- a/clearing-parent/clearing-validation/src/main/java/ru/spcex/clearing/util/services/exchangers/BiDirectionQueueExchanger.java
+++ b/clearing-parent/clearing-validation/src/main/java/ru/spcex/clearing/util/services/exchangers/BiDirectionQueueExchanger.java
@@ -27,6 +27,8 @@ import java.util.concurrent.Future;
  * <p>
  * Ожидает из очереди (CommonIdRequest)
  *
+ * Похожая функция ожидания: KafkaSender.sendToQueueWaitForAnswer
+ *
  * @param <TOut> отправляется в очередь
  */
 public class BiDirectionQueueExchanger<TOut extends BaseRequest<?>> extends QueueConsumer implements Closeable {
diff --git a/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/AbstractExporterService.java b/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/AbstractExporterService.java
index b26a02678..5d3989f4f 100644
--- a/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/AbstractExporterService.java
+++ b/clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/AbstractExporterService.java
@@ -1,7 +1,5 @@
 package ru.spcex.clearing.lim.exporter.services;
 
-import org.apache.kafka.clients.producer.Producer;
-import org.apache.kafka.clients.producer.ProducerRecord;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.util.StringUtils;
@@ -74,7 +72,7 @@ public abstract class AbstractExporterService {
         sendLimExportedNotification(fileName);
     }
 
-    private void sendLimExportedNotification(String fileName) {
+    void sendLimExportedNotification(String fileName) {
         LimExportedRequest limExportedRequest = new LimExportedRequest();
         limExportedRequest.setLimFileName(fileName);
         log.debug("Send message to kafka \"{}\": {}", LIM_EXPORTED, LogFormatter.toStringWrapper(limExportedRequest));
diff --git a/clearing-parent/lim-exporter/src/test/java/ru/spcex/clearing/lim/exporter/services/AbstractExporterServiceTest.java b/clearing-parent/lim-exporter/src/test/java/ru/spcex/clearing/lim/exporter/services/AbstractExporterServiceTest.java
new file mode 100644
index 000000000..d1a6bfa32
--- /dev/null
+++ b/clearing-parent/lim-exporter/src/test/java/ru/spcex/clearing/lim/exporter/services/AbstractExporterServiceTest.java
@@ -0,0 +1,27 @@
+package ru.spcex.clearing.lim.exporter.services;
+
+import org.junit.jupiter.api.Test;
+import ru.spcex.clearing.lim.exporter.AbstractServiceTest;
+import ru.spcex.clearing.test.TestUtils;
+
+import javax.annotation.PostConstruct;
+
+import java.time.LocalDateTime;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+class AbstractExporterServiceTest extends AbstractServiceTest {
+    @PostConstruct
+    public void init() {
+        super.init();
+    }
+
+    @Test
+    void sendLimExportedNotification() {
+        AbstractExporterService moneyExporterService = new MoneyExporterService(null, kafkaSender, imdgProvider);
+
+        String fileName = "limits_money_202305241832.lim";
+        moneyExporterService.sendLimExportedNotification(fileName);
+        //TestUtils.waitingSendAndCheckRecord(null, mockProducer);
+    }
+}
\ No newline at end of file