From 6b7d0762dce9afdda95c0ec74ef57232d79a9dd4 Mon Sep 17 00:00:00 2001 From: Maverick Studer Date: Thu, 29 Aug 2024 13:14:34 +0200 Subject: [PATCH] Fix migration --- .../llm/service/queue/MessagingConfiguration.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/llm-service/llm-service-server/src/main/java/com/knecon/fforesight/llm/service/queue/MessagingConfiguration.java b/llm-service/llm-service-server/src/main/java/com/knecon/fforesight/llm/service/queue/MessagingConfiguration.java index ebdaa9c..f50fd0f 100644 --- a/llm-service/llm-service-server/src/main/java/com/knecon/fforesight/llm/service/queue/MessagingConfiguration.java +++ b/llm-service/llm-service-server/src/main/java/com/knecon/fforesight/llm/service/queue/MessagingConfiguration.java @@ -1,7 +1,9 @@ package com.knecon.fforesight.llm.service.queue; import static com.knecon.fforesight.llm.service.QueueNames.LLM_NER_DLQ; +import static com.knecon.fforesight.llm.service.QueueNames.LLM_NER_REQUEST_EXCHANGE; +import org.springframework.amqp.core.DirectExchange; import org.springframework.amqp.core.Queue; import org.springframework.amqp.core.QueueBuilder; import org.springframework.context.annotation.Bean; @@ -13,8 +15,15 @@ import lombok.RequiredArgsConstructor; @RequiredArgsConstructor public class MessagingConfiguration { + @Bean - public Queue llmNerResponseDLQ() { + public DirectExchange llmNerRequestExchange() { + + return new DirectExchange(LLM_NER_REQUEST_EXCHANGE); + } + + @Bean + public Queue llmNerDLQ() { return QueueBuilder.durable(LLM_NER_DLQ).build(); }