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;
*
* Ожидает из очереди (CommonIdRequest)
*
+ * Похожая функция ожидания: KafkaSender.sendToQueueWaitForAnswer
+ *
* @param отправляется в очередь
*/
public class BiDirectionQueueExchanger> 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