Merge pull request #5 from protegeproject/fix-set-timeout-on-asyncrab…

…bittemplate Set time out in RabbitMq async rabbit template
protegeproject · Jun 17, 2024 · 250cd37 · 250cd37
2 parents 68368b3 + 79e310f
commit 250cd37
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/main/java/edu/stanford/protege/webprotege/ipc/impl/RabbitMqConfiguration.java b/src/main/java/edu/stanford/protege/webprotege/ipc/impl/RabbitMqConfiguration.java
@@ -94,7 +94,11 @@ public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
     @Bean(name = "asyncRabbitTemplate")
     @ConditionalOnProperty(prefix = "webprotege.rabbitmq", name = "commands-subscribe", havingValue = "true", matchIfMissing = true)
     public AsyncRabbitTemplate asyncRabbitTemplate(@Qualifier("rabbitTemplate") RabbitTemplate rabbitTemplate, SimpleMessageListenerContainer replyListenerContainer) {
-        return new AsyncRabbitTemplate(rabbitTemplate, replyListenerContainer, getCommandResponseQueue());
+        var asyncRabbitTemplate = new AsyncRabbitTemplate(rabbitTemplate,
+                                                          replyListenerContainer,
+                                                          getCommandResponseQueue());
+        asyncRabbitTemplate.setReceiveTimeout(rabbitMqTimeout);
+        return asyncRabbitTemplate;
     }