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