From 41a95db83f708c6137219140ef2c4c82f54957fb Mon Sep 17 00:00:00 2001
From: backdev-1 <backdev-1@xxxxxxxxx.su>
Date: Thu, 11 Jun 2026 15:06:59 +0700
Subject: [PATCH] Add monitoring with another system

---
 .../ru/soune/nocopy/kafka/MonitoringResultListener.java  | 9 +--------
 1 file changed, 1 insertion(+), 8 deletions(-)

diff --git a/src/main/java/ru/soune/nocopy/kafka/MonitoringResultListener.java b/src/main/java/ru/soune/nocopy/kafka/MonitoringResultListener.java
index e47b1aa..a4ab460 100644
--- a/src/main/java/ru/soune/nocopy/kafka/MonitoringResultListener.java
+++ b/src/main/java/ru/soune/nocopy/kafka/MonitoringResultListener.java
@@ -1,7 +1,5 @@
 package ru.soune.nocopy.kafka;
 
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.kafka.annotation.KafkaListener;
@@ -16,13 +14,8 @@ public class MonitoringResultListener {
 
     private final ViolationService violationService;
 
-    private final ObjectMapper objectMapper;
-
     @KafkaListener(topics = "monitoring-results", groupId = "dashboard")
-    public void handleCommand(String message) throws JsonProcessingException {
-        YandexSearchResponse.ImageResult imageResult =
-                objectMapper.readValue(message, YandexSearchResponse.ImageResult.class);
-
+    public void handleCommand(YandexSearchResponse.ImageResult imageResult) {
         violationService.processViolation(imageResult.getUrl(), imageResult.getHost(), imageResult.getPageUrl(),
                 imageResult.getFileId(), imageResult.getPageTitle());
     }