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<T> message = objectMapper.readValue(kafkaMessage, messageType);
 
-      if (Boolean.TRUE.equals(message.isSuccess())
-          && message.getData() != null) {
+      if (message.isSuccess() && message.getData() != null) {
         DataProcessor<T, ?> processor = (DataProcessor<T, ?>) 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<T, ?> processor = (DataProcessor<T, ?>) 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<T> message = objectMapper.readValue(kafkaMessage, messageType);
 
-
-      if (Boolean.TRUE.equals(message.isSuccess()) && message.getData() != null) {
+      if (message.isSuccess() && message.getData() != null) {
         DataProcessor<T, ?> processor = (DataProcessor<T, ?>) dataProcessors.get(entityClass);
-
         if (processor instanceof LinkDataProcessor<T, ?> linkProcessor) {
           linkProcessor.deleteLink(message.getData());
         }