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

SUPPORT-8474: Fix

Browse source
This commit is contained in:
Eduard Tihomirov 2024-09-12 15:34:26 +03:00
parent 3c0b7bc0e8
commit 679ddea997
3 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -30,8 +30,8 @@ public class ReplyingKafkaConfig {
@Value("${ervu-kafka.group-id}")
private String groupId;
@Value("${ervu-kafka.reply-connection-timeout:30}")
private long connectionTimeout;
@Value("${ervu-kafka.reply-timeout:30}")
private long replyTimeout;
@Bean
public ProducerFactory<String, String> producerFactory() {
@ -80,7 +80,7 @@ public class ReplyingKafkaConfig {
ReplyingKafkaTemplate<String, String, String> replyingKafkaTemplate =
new ReplyingKafkaTemplate<>(pf, container);
replyingKafkaTemplate.setCorrelationHeaderName("messageID");
replyingKafkaTemplate.setDefaultReplyTimeout(Duration.ofSeconds(connectionTimeout));
replyingKafkaTemplate.setDefaultReplyTimeout(Duration.ofSeconds(replyTimeout));
return replyingKafkaTemplate;
}
}

2
config/patches/default.cli
View file

@ -41,4 +41,4 @@ xa-data-source add \
/system-property=ervu-kafka.org-reply-topic:add(value="ervu.organization.response")
/system-property=ervu-kafka.group-id:add(value="1")
/system-property=ervu-kafka.org-request-topic:add(value="ervu.organization.request")
/system-property=ervu-kafka.reply-connection-timeout:add(value="30")
/system-property=ervu-kafka.reply-timeout:add(value="30")

2
config/standalone/dev/standalone.xml
View file

@ -68,7 +68,7 @@
<property name="ervu-kafka.reply-topic" value="ervu.lkpr.person.search.response"/>
<property name="ervu-kafka.group-id" value="1"/>
<property name="ervu-kafka.request-topic" value="ervu.lkpr.person.search.request"/>
<property name="ervu-kafka.reply-connection-timeout" value="30"/>
<property name="ervu-kafka.reply-timeout" value="30"/>
</system-properties>
<management>
<audit-log>