diff --git a/src/main/java/ru/no_copy/monitoring/MonitoringApplication.java b/src/main/java/ru/no_copy/monitoring/MonitoringApplication.java index 99618c6..c1eff16 100644 --- a/src/main/java/ru/no_copy/monitoring/MonitoringApplication.java +++ b/src/main/java/ru/no_copy/monitoring/MonitoringApplication.java @@ -2,7 +2,6 @@ package ru.no_copy.monitoring; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.scheduling.annotation.EnableScheduling; @SpringBootApplication public class MonitoringApplication { diff --git a/src/main/java/ru/no_copy/monitoring/service/MonitoringService.java b/src/main/java/ru/no_copy/monitoring/service/MonitoringService.java index cb99a42..c9f15ee 100644 --- a/src/main/java/ru/no_copy/monitoring/service/MonitoringService.java +++ b/src/main/java/ru/no_copy/monitoring/service/MonitoringService.java @@ -22,7 +22,7 @@ public class MonitoringService { private final ObjectMapper objectMapper; - private final KafkaTemplate kafkaTemplate; + private final KafkaTemplate kafkaTemplate; public void execute(String message) throws IOException, TimeoutException { MonitoringDTO monitoring; @@ -45,7 +45,7 @@ public class MonitoringService { log.info("Images count: {}", images.size()); for (SearchResponse.ImageResult imageResult: images) { - kafkaTemplate.send("monitoring-results", imageResult); + kafkaTemplate.send("monitoring-results", objectMapper.writeValueAsString(imageResult)); } } } diff --git a/src/test/java/ru/no_copy/monitoring/MonitoringApplicationTests.java b/src/test/java/ru/no_copy/monitoring/MonitoringApplicationTests.java deleted file mode 100644 index 9246d03..0000000 --- a/src/test/java/ru/no_copy/monitoring/MonitoringApplicationTests.java +++ /dev/null @@ -1,13 +0,0 @@ -package ru.no_copy.monitoring; - -import org.junit.jupiter.api.Test; -import org.springframework.boot.test.context.SpringBootTest; - -@SpringBootTest -class MonitoringApplicationTests { - - @Test - void contextLoads() { - } - -}