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() );