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

SUPPORT-9213: fix

Browse source
This commit is contained in:
adel.ka 2025-06-18 16:01:08 +03:00
parent 22538bf370
commit d5e7be212b
1 changed files with 1 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -3,7 +3,6 @@ package ru.micord.ervu.account_applications.kafka;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener; import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import ru.micord.ervu.account_applications.db_beans.public_.tables.Solution;
import ru.micord.ervu.account_applications.model.*; import ru.micord.ervu.account_applications.model.*;
import ru.micord.ervu.account_applications.service.ErvuDirectoriesService; import ru.micord.ervu.account_applications.service.ErvuDirectoriesService;
@ -28,7 +27,7 @@ public class ErvuDirectoriesListener {
@KafkaListener(id = "${kafka.solution.group.id}", topics = "${kafka.solution.reconciliation}") @KafkaListener(id = "${kafka.solution.group.id}", topics = "${kafka.solution.reconciliation}")
public void listenKafkaSolution(String kafkaMessage) { public void listenKafkaSolution(String kafkaMessage) {
ervuDirectoriesService.processUpsertMessage(kafkaMessage, Solution.class); ervuDirectoriesService.processUpsertMessage(kafkaMessage, SolutionData.class);
} }
@KafkaListener(id = "${kafka.domain.updated.group.id}", topics = "${kafka.domain.updated}") @KafkaListener(id = "${kafka.domain.updated.group.id}", topics = "${kafka.domain.updated}")