From b90f4328b9f93f636815dc16bcae355d9839a72c Mon Sep 17 00:00:00 2001 From: "adel.ka" Date: Thu, 12 Jun 2025 19:47:43 +0300 Subject: [PATCH] =?UTF-8?q?SUPPORT-9212:=20=D1=84=D0=B8=D0=BA=D1=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend/src/main/java/AppConfig.java | 6 +++++- .../service/IdmDirectoriesService.java | 10 +++------- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/backend/src/main/java/AppConfig.java b/backend/src/main/java/AppConfig.java index 0f3d6fd..4e01d7d 100644 --- a/backend/src/main/java/AppConfig.java +++ b/backend/src/main/java/AppConfig.java @@ -19,7 +19,11 @@ import net.javacrumbs.shedlock.spring.ScheduledLockConfigurationBuilder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Qualifier; -import org.springframework.context.annotation.*; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.ComponentScan; +import org.springframework.context.annotation.Configuration; +import org.springframework.context.annotation.EnableAspectJAutoProxy; +import org.springframework.context.annotation.FilterType; import org.springframework.context.support.PropertySourcesPlaceholderConfigurer; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; diff --git a/backend/src/main/java/ervu_business_metrics/service/IdmDirectoriesService.java b/backend/src/main/java/ervu_business_metrics/service/IdmDirectoriesService.java index 4890184..73ca68d 100644 --- a/backend/src/main/java/ervu_business_metrics/service/IdmDirectoriesService.java +++ b/backend/src/main/java/ervu_business_metrics/service/IdmDirectoriesService.java @@ -81,8 +81,7 @@ public class IdmDirectoriesService { UpsertMessage message = objectMapper.readValue(kafkaMessage, messageType); - if (Boolean.TRUE.equals(message.isSuccess()) - && message.getData() != null) { + if (message.isSuccess() && message.getData() != null) { DataProcessor processor = (DataProcessor) dataProcessors.get(entityClass); if (processor == null) { throw new IllegalStateException("No processor found for " + entityClass.getSimpleName()); @@ -103,8 +102,7 @@ public class IdmDirectoriesService { ChangeActiveMessage.class ); - if (Boolean.TRUE.equals(changeActiveMessage.isSuccess()) - && changeActiveMessage.getData() != null) { + if (changeActiveMessage.isSuccess() && changeActiveMessage.getData() != null) { DataProcessor processor = (DataProcessor) dataProcessors.get(entityClass); if (processor == null) { throw new IllegalStateException("No processor found for " + entityClass.getSimpleName()); @@ -125,10 +123,8 @@ public class IdmDirectoriesService { .constructParametricType(DeleteLinkMessage.class, entityClass); DeleteLinkMessage message = objectMapper.readValue(kafkaMessage, messageType); - - if (Boolean.TRUE.equals(message.isSuccess()) && message.getData() != null) { + if (message.isSuccess() && message.getData() != null) { DataProcessor processor = (DataProcessor) dataProcessors.get(entityClass); - if (processor instanceof LinkDataProcessor linkProcessor) { linkProcessor.deleteLink(message.getData()); }