fix after merge

This commit is contained in:
gulnaz 2025-02-17 13:13:20 +03:00
parent 0069dcfa5a
commit 7e05acb670

View file

@ -373,11 +373,21 @@ public class EsiaAuthService {
}
public Response getErvuIdResponse(PersonModel personModel) throws JsonProcessingException {
Person person = copyToPerson(personModel);
String kafkaResponse = replyingKafkaService.sendMessageAndGetReply(requestTopic,
requestReplyTopic, objectMapper.writeValueAsString(person)
);
return objectMapper.readValue(kafkaResponse, Response.class);
long requestIdERVU = 0;
try {
Person person = copyToPerson(personModel);
long startTime = System.currentTimeMillis();
String kafkaResponse = replyingKafkaService.sendMessageAndGetReply(requestTopic,
requestReplyTopic, objectMapper.writeValueAsString(person)
);
requestIdERVU = System.currentTimeMillis() - startTime;
return objectMapper.readValue(kafkaResponse, Response.class);
}
finally {
LOGGER.info("Thread {}: RequestIdERVU: {}ms",
Thread.currentThread().getId(), requestIdERVU);
}
}
private Person copyToPerson(PersonModel personModel) {