From c7fbd371c34414e2c9d3ff0c625226b9898ef31d Mon Sep 17 00:00:00 2001 From: backdev-1 Date: Thu, 11 Jun 2026 15:34:00 +0700 Subject: [PATCH] Add monitoring with another system --- .../java/ru/soune/nocopy/kafka/MonitoringResultListener.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/ru/soune/nocopy/kafka/MonitoringResultListener.java b/src/main/java/ru/soune/nocopy/kafka/MonitoringResultListener.java index 6e3ef07..2242ef8 100644 --- a/src/main/java/ru/soune/nocopy/kafka/MonitoringResultListener.java +++ b/src/main/java/ru/soune/nocopy/kafka/MonitoringResultListener.java @@ -19,10 +19,12 @@ public class MonitoringResultListener { @KafkaListener(topics = "monitoring-results", groupId = "dashboard") public void handleCommand(String message) { + log.info("Get message for create violation"); + try { YandexSearchResponse.ImageResult imageResult = objectMapper.readValue(message, YandexSearchResponse.ImageResult.class); - + log.info("Image result: {}", imageResult); violationService.processViolation(imageResult.getUrl(), imageResult.getHost(), imageResult.getPageUrl(), imageResult.getFileId(), imageResult.getPageTitle() );