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