From 3b320bfb00b898761df6e4317c901d33722058d9 Mon Sep 17 00:00:00 2001 From: Timo Bejan Date: Wed, 6 Mar 2024 16:50:29 +0200 Subject: [PATCH] orchestrator/persistence service should control queues --- .../server/queue/MessagingConfiguration.java | 26 ------------------- 1 file changed, 26 deletions(-) diff --git a/ocr-service-v1/ocr-service-server/src/main/java/com/knecon/fforesight/service/ocr/v1/server/queue/MessagingConfiguration.java b/ocr-service-v1/ocr-service-server/src/main/java/com/knecon/fforesight/service/ocr/v1/server/queue/MessagingConfiguration.java index ae57dbc..d51f81b 100644 --- a/ocr-service-v1/ocr-service-server/src/main/java/com/knecon/fforesight/service/ocr/v1/server/queue/MessagingConfiguration.java +++ b/ocr-service-v1/ocr-service-server/src/main/java/com/knecon/fforesight/service/ocr/v1/server/queue/MessagingConfiguration.java @@ -13,34 +13,8 @@ public class MessagingConfiguration { public static final String OCR_REQUEST_QUEUE = "ocr_request_queue"; public static final String OCR_RESPONSE_QUEUE = "ocr_response_queue"; - public static final String OCR_DLQ = "ocr_dead_letter_queue"; - - public static final String X_DEAD_LETTER_EXCHANGE = "x-dead-letter-exchange"; - public static final String X_DEAD_LETTER_ROUTING_KEY = "x-dead-letter-routing-key"; - public static final String X_MAX_PRIORITY = "x-max-priority"; - public static final String OCR_STATUS_UPDATE_RESPONSE_QUEUE = "ocr_status_update_response_queue"; - public static final String X_ERROR_INFO_HEADER = "x-error-message"; public static final String X_ERROR_INFO_TIMESTAMP_HEADER = "x-error-message-timestamp"; - - @Bean - public Queue ocrQueue() { - - return QueueBuilder.durable(OCR_REQUEST_QUEUE) - .withArgument(X_DEAD_LETTER_EXCHANGE, "") - .withArgument(X_DEAD_LETTER_ROUTING_KEY, OCR_DLQ) - .withArgument(X_MAX_PRIORITY, 2) - .maxPriority(2) - .build(); - } - - - @Bean - public Queue ocrDeadLetterQueue() { - - return QueueBuilder.durable(OCR_DLQ).build(); - } - }