diff --git a/layoutparser-service/layoutparser-service-internal-api/src/main/java/com/knecon/fforesight/service/layoutparser/internal/api/queue/LayoutParsingQueueNames.java b/layoutparser-service/layoutparser-service-internal-api/src/main/java/com/knecon/fforesight/service/layoutparser/internal/api/queue/LayoutParsingQueueNames.java index 4aabd62..081f5ea 100644 --- a/layoutparser-service/layoutparser-service-internal-api/src/main/java/com/knecon/fforesight/service/layoutparser/internal/api/queue/LayoutParsingQueueNames.java +++ b/layoutparser-service/layoutparser-service-internal-api/src/main/java/com/knecon/fforesight/service/layoutparser/internal/api/queue/LayoutParsingQueueNames.java @@ -3,6 +3,5 @@ package com.knecon.fforesight.service.layoutparser.internal.api.queue; public class LayoutParsingQueueNames { public static final String LAYOUT_PARSING_REQUEST_QUEUE = "layout_parsing_request_queue"; - public static final String LAYOUT_PARSING_DLQ = "layout_parsing_dead_letter_queue"; public static final String LAYOUT_PARSING_FINISHED_EVENT_QUEUE = "layout_parsing_response_queue"; } diff --git a/layoutparser-service/layoutparser-service-server/src/main/java/com/knecon/fforesight/service/layoutparser/server/queue/MessagingConfiguration.java b/layoutparser-service/layoutparser-service-server/src/main/java/com/knecon/fforesight/service/layoutparser/server/queue/MessagingConfiguration.java deleted file mode 100644 index fc061df..0000000 --- a/layoutparser-service/layoutparser-service-server/src/main/java/com/knecon/fforesight/service/layoutparser/server/queue/MessagingConfiguration.java +++ /dev/null @@ -1,37 +0,0 @@ -package com.knecon.fforesight.service.layoutparser.server.queue; - -import org.springframework.amqp.core.Queue; -import org.springframework.amqp.core.QueueBuilder; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -import com.knecon.fforesight.service.layoutparser.internal.api.queue.LayoutParsingQueueNames; - -import lombok.RequiredArgsConstructor; - -@Configuration -@RequiredArgsConstructor -public class MessagingConfiguration { - - @Bean - public Queue layoutparsingRequestQueue() { - - return QueueBuilder.durable(LayoutParsingQueueNames.LAYOUT_PARSING_REQUEST_QUEUE)// - .withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", LayoutParsingQueueNames.LAYOUT_PARSING_DLQ).build(); - } - - - @Bean - public Queue layoutparsingResponseQueue() { - - return QueueBuilder.durable(LayoutParsingQueueNames.LAYOUT_PARSING_FINISHED_EVENT_QUEUE).build(); - } - - - @Bean - public Queue layoutparsingDLQ() { - - return QueueBuilder.durable(LayoutParsingQueueNames.LAYOUT_PARSING_DLQ).build(); - } - -}