Marmelator/llm-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 44 Wiki Activity

Fix migration

Browse Source
This commit is contained in:
Maverick Studer 2024-08-29 13:14:34 +02:00
parent 72b7ec7a3f
commit 6b7d0762dc
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
llm-service/llm-service-server/src/main/java/com/knecon/fforesight/llm/service/queue/MessagingConfiguration.java
View File

@ -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();
}