micord/ervu-account-applications
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix

Browse source
This commit is contained in:
Eduard Tihomirov 2025-04-22 12:48:14 +03:00
parent bafe64e6af
commit d1716cd9c8
2 changed files with 22 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -14,14 +14,12 @@ public class ErvuDirectoriesListener {
@Autowired @Autowired
private ErvuDirectoriesService ervuDirectoriesService; private ErvuDirectoriesService ervuDirectoriesService;
@KafkaListener(id = "${kafka.domain.group.id}", topics = "${kafka.domain.reconciliation}", @KafkaListener(id = "${kafka.domain.group.id}", topics = "${kafka.domain.reconciliation}")
autoStartup = "false")
public void listenKafkaDomain(String kafkaMessage) { public void listenKafkaDomain(String kafkaMessage) {
ervuDirectoriesService.upsertKafkaDomainMessage(kafkaMessage); ervuDirectoriesService.upsertKafkaDomainMessage(kafkaMessage);
} }
@KafkaListener(id = "${kafka.role.group.id}", topics = "${kafka.role.reconciliation}", @KafkaListener(id = "${kafka.role.group.id}", topics = "${kafka.role.reconciliation}")
autoStartup = "false")
public void listenKafkaRole(String kafkaMessage) { public void listenKafkaRole(String kafkaMessage) {
ervuDirectoriesService.upsertKafkaRoleMessage(kafkaMessage); ervuDirectoriesService.upsertKafkaRoleMessage(kafkaMessage);
} }

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

@ -1,9 +1,8 @@
package ru.micord.ervu.account_applications.kafka; package ru.micord.ervu.account_applications.kafka;
import javax.annotation.PostConstruct;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.DependsOn; import org.springframework.context.annotation.DependsOn;
import org.springframework.kafka.config.KafkaListenerEndpointRegistry;
import org.springframework.kafka.listener.MessageListenerContainer;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import ru.micord.ervu.account_applications.service.ErvuDirectoriesService; import ru.micord.ervu.account_applications.service.ErvuDirectoriesService;
@ -13,22 +12,29 @@ import ru.micord.ervu.account_applications.service.ErvuDirectoriesService;
@Component @Component
@DependsOn("ervuDirectoriesListener") @DependsOn("ervuDirectoriesListener")
public class KafkaConsumerInitializer { public class KafkaConsumerInitializer {
@Value("${kafka.domain.group.id}")
private String domainGroupId;
@Value("${kafka.role.group.id}")
private String roleGroupId;
@Value("${load.directories:true}") @Value("${load.directories:true}")
private Boolean loadDirectories; private Boolean loadDirectories;
public KafkaConsumerInitializer(KafkaListenerEndpointRegistry kafkaListenerEndpointRegistry, ErvuDirectoriesService ervuDirectoriesService) { private final ErvuDirectoriesService ervuDirectoriesService;
MessageListenerContainer listenerContainerDomain = kafkaListenerEndpointRegistry.getListenerContainer(domainGroupId);
MessageListenerContainer listenerContainerRole = kafkaListenerEndpointRegistry.getListenerContainer(roleGroupId); public KafkaConsumerInitializer(ErvuDirectoriesService ervuDirectoriesService) {
listenerContainerDomain.start(); this.ervuDirectoriesService = ervuDirectoriesService;
listenerContainerRole.start(); }
@PostConstruct
public void init() {
if (loadDirectories) { if (loadDirectories) {
new Thread(ervuDirectoriesService::updateDirectories).start(); new Thread(this::runWithSleep).start();
} }
} }
private void runWithSleep() {
try {
Thread.sleep(10000);
}
catch (InterruptedException e) {
throw new RuntimeException(e);
}
ervuDirectoriesService.updateDirectories();
}
} }