diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/configuration/MessagingConfiguration.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/configuration/MessagingConfiguration.java index 9437fa4a1..cb51b32f6 100644 --- a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/configuration/MessagingConfiguration.java +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/configuration/MessagingConfiguration.java @@ -253,12 +253,12 @@ public class MessagingConfiguration { .build(); } + @Bean @ConditionalOnProperty(prefix = "persistence-service", name = "migrateOnly", havingValue = "false") public Queue ocrResponseQueue() { - return QueueBuilder.durable(OCR_RESPONSE_QUEUE) - .build(); + return QueueBuilder.durable(OCR_RESPONSE_QUEUE).build(); } @@ -266,8 +266,7 @@ public class MessagingConfiguration { @ConditionalOnProperty(prefix = "persistence-service", name = "migrateOnly", havingValue = "false") public Queue ocrDLQ() { - return QueueBuilder.durable(OCR_DLQ) - .build(); + return QueueBuilder.durable(OCR_DLQ).build(); } @@ -449,7 +448,10 @@ public class MessagingConfiguration { @Bean public Queue layoutparsingResponseQueue() { - return QueueBuilder.durable(LAYOUT_PARSING_FINISHED_EVENT_QUEUE).build(); + return QueueBuilder.durable(LAYOUT_PARSING_FINISHED_EVENT_QUEUE) + .withArgument("x-dead-letter-exchange", "") + .withArgument("x-dead-letter-routing-key", LAYOUT_PARSING_DLQ) + .build(); }