Revert "SUPPORT-9115: Fix"

This reverts commit fe1b79202c.

backend/src/main/java/ru/micord/ervu/account_applications/kafka/ErvuDirectoriesListener.java

@@ -0,0 +1,48 @@
+package ru.micord.ervu.account_applications.kafka;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.stereotype.Component;
+import ru.micord.ervu.account_applications.service.ErvuDirectoriesService;
+
+/**
+ * @author Eduard Tihomirov
+ */
+@Component
+public class ErvuDirectoriesListener {
+
+  @Autowired
+  private ErvuDirectoriesService ervuDirectoriesService;
+
+  @KafkaListener(id = "${kafka.domain.group.id}", topics = "${kafka.domain.reconciliation}",
+      autoStartup = "false")
+  public void listenKafkaDomain(String kafkaMessage) {
+    ervuDirectoriesService.upsertKafkaDomainMessage(kafkaMessage);
+  }
+
+  @KafkaListener(id = "${kafka.role.group.id}", topics = "${kafka.role.reconciliation}",
+      autoStartup = "false")
+  public void listenKafkaRole(String kafkaMessage) {
+    ervuDirectoriesService.upsertKafkaRoleMessage(kafkaMessage);
+  }
+// Пока не заведены, обещают в будущих апдейтах создать
+//  @KafkaListener(id = "${kafka.role.updated.group.id}", topics = "${kafka.role.updated}")
+//  public void listenKafkaRoleUpdated(String kafkaMessage) {
+//    ervuDirectoriesService.upsertKafkaRoleMessage(kafkaMessage);
+//  }
+
+  //  @KafkaListener(id = "${kafka.role.created.group.id}", topics = "${kafka.role.created}")
+//  public void listenKafkaRoleUpdated(String kafkaMessage) {
+//    ervuDirectoriesService.upsertKafkaRoleMessage(kafkaMessage);
+//  }
+
+  @KafkaListener(id = "${kafka.domain.updated.group.id}", topics = "${kafka.domain.updated}")
+  public void listenKafkaDomainUpdated(String kafkaMessage) {
+    ervuDirectoriesService.upsertKafkaDomainMessage(kafkaMessage);
+  }
+
+  @KafkaListener(id = "${kafka.domain.created.group.id}", topics = "${kafka.domain.created}")
+  public void listenKafkaDomainCreated(String kafkaMessage) {
+    ervuDirectoriesService.upsertKafkaDomainMessage(kafkaMessage);
+  }
+}

backend/src/main/java/ru/micord/ervu/account_applications/kafka/KafkaConsumerInitializer.java

@@ -0,0 +1,27 @@
+package ru.micord.ervu.account_applications.kafka;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.DependsOn;
+import org.springframework.kafka.config.KafkaListenerEndpointRegistry;
+import org.springframework.kafka.listener.MessageListenerContainer;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Eduard Tihomirov
+ */
+@Component
+@DependsOn("ervuDirectoriesListener")
+public class KafkaConsumerInitializer {
+  @Value("${kafka.domain.group.id}")
+  private String domainGroupId;
+
+  @Value("${kafka.role.group.id}")
+  private String roleGroupId;
+
+  public KafkaConsumerInitializer(KafkaListenerEndpointRegistry kafkaListenerEndpointRegistry) {
+    MessageListenerContainer listenerContainerDomain = kafkaListenerEndpointRegistry.getListenerContainer(domainGroupId);
+    MessageListenerContainer listenerContainerRole = kafkaListenerEndpointRegistry.getListenerContainer(roleGroupId);
+    listenerContainerDomain.start();
+    listenerContainerRole.start();
+  }
+}

backend/src/main/java/ru/micord/ervu/account_applications/service/ErvuDirectoriesService.java

@@ -9,8 +9,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.UUID;
 
-import javax.annotation.PostConstruct;
-
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.slf4j.Logger;
@@ -24,9 +22,6 @@ import org.springframework.http.HttpEntity;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
-import org.springframework.kafka.annotation.KafkaListener;
-import org.springframework.kafka.config.KafkaListenerEndpointRegistry;
-import org.springframework.kafka.listener.MessageListenerContainer;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.client.RestTemplate;
@@ -39,7 +34,7 @@ import ru.micord.ervu.account_applications.model.RoleResponse;
  * @author Eduard Tihomirov
  */
 @Service
-@DependsOn("liquibase")
+@DependsOn({"liquibase", "ervuDirectoriesListener"})
 public class ErvuDirectoriesService {
   private static final Logger LOGGER = LoggerFactory.getLogger(
       MethodHandles.lookup().lookupClass());
@@ -49,67 +44,12 @@ public class ErvuDirectoriesService {
   private String ervuDirectories;
   @Value("${ervu.admin.role:gomu_supervisor, system_administrator, security_administrator}")
   private String ervuAdminRole;
-  @Value("${load.directories:true}")
-  private Boolean loadDirectories;
-  @Value("${kafka.domain.group.id}")
-  private String domainGroupId;
-  @Value("${kafka.role.group.id}")
-  private String roleGroupId;
   @Autowired
   private RestTemplate restTemplate;
   @Autowired
   private ErvuDirectoriesDaoService ervuDirectoriesDaoService;
   @Autowired
   private ObjectMapper objectMapper;
-  @Autowired
-  private KafkaListenerEndpointRegistry kafkaListenerEndpointRegistry;
-
-  @PostConstruct
-  public void init() {
-    MessageListenerContainer listenerContainerDomain = kafkaListenerEndpointRegistry.getListenerContainer(domainGroupId);
-    MessageListenerContainer listenerContainerRole = kafkaListenerEndpointRegistry.getListenerContainer(roleGroupId);
-    listenerContainerDomain.start();
-    listenerContainerRole.start();
-    if (loadDirectories) {
-      new Thread(this::updateDirectories).start();
-    }
-  }
-
-  @KafkaListener(id = "${kafka.domain.group.id}", topics = "${kafka.domain.reconciliation}",
-      autoStartup = "false")
-  @Transactional
-  public void listenKafkaDomain(String kafkaMessage) {
-    upsertKafkaDomainMessage(kafkaMessage);
-  }
-
-  @KafkaListener(id = "${kafka.role.group.id}", topics = "${kafka.role.reconciliation}",
-      autoStartup = "false")
-  @Transactional
-  public void listenKafkaRole(String kafkaMessage) {
-    upsertKafkaRoleMessage(kafkaMessage);
-  }
-// Пока не заведены, обещают в будущих апдейтах создать
-//  @KafkaListener(id = "${kafka.role.updated.group.id}", topics = "${kafka.role.updated}")
-//  public void listenKafkaRoleUpdated(String kafkaMessage) {
-//    ervuDirectoriesService.upsertKafkaRoleMessage(kafkaMessage);
-//  }
-
-  //  @KafkaListener(id = "${kafka.role.created.group.id}", topics = "${kafka.role.created}")
-//  public void listenKafkaRoleUpdated(String kafkaMessage) {
-//    ervuDirectoriesService.upsertKafkaRoleMessage(kafkaMessage);
-//  }
-
-  @KafkaListener(id = "${kafka.domain.updated.group.id}", topics = "${kafka.domain.updated}")
-  @Transactional
-  public void listenKafkaDomainUpdated(String kafkaMessage) {
-    upsertKafkaDomainMessage(kafkaMessage);
-  }
-
-  @KafkaListener(id = "${kafka.domain.created.group.id}", topics = "${kafka.domain.created}")
-  @Transactional
-  public void listenKafkaDomainCreated(String kafkaMessage) {
-    upsertKafkaDomainMessage(kafkaMessage);
-  }
 
 
   @Caching(evict = {
@@ -141,6 +81,7 @@ public class ErvuDirectoriesService {
 
   }
 
+  @Transactional
   public void upsertKafkaDomainMessage(String kafkaMessage) {
     RecruitmentResponse[] recruitmentResponses;
     try {
@@ -154,6 +95,7 @@ public class ErvuDirectoriesService {
     }
   }
 
+  @Transactional
   public void upsertKafkaRoleMessage(String kafkaMessage) {
     RoleResponse[] roleResponses;
     try {