Add monitoring with another system

2026-06-11 15:34:00 +07:00
parent 30df7fe83f
commit c7fbd371c3
1 changed files with 3 additions and 1 deletions
@@ -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()
            );