Marmelator/persistence-service
1
0
Fork 0
Code Issues Pull Requests 17 Actions Packages Projects Releases 1.1k Wiki Activity

Merge branch 'RED-10027' into 'release/2.465.x'

Browse Source 
RED-10027 - Add x-dead-letter-exchange argument

See merge request redactmanager/persistence-service!740
This commit is contained in:
Andrei Isvoran 2024-09-16 13:46:47 +02:00
commit 93a3728a9d
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/configuration/MessagingConfiguration.java
View File

@ -253,12 +253,12 @@ public class MessagingConfiguration {
.build(); .build();
} }
@Bean @Bean
@ConditionalOnProperty(prefix = "persistence-service", name = "migrateOnly", havingValue = "false") @ConditionalOnProperty(prefix = "persistence-service", name = "migrateOnly", havingValue = "false")
public Queue ocrResponseQueue() { public Queue ocrResponseQueue() {
return QueueBuilder.durable(OCR_RESPONSE_QUEUE) return QueueBuilder.durable(OCR_RESPONSE_QUEUE).build();
.build();
} }
@ -266,8 +266,7 @@ public class MessagingConfiguration {
@ConditionalOnProperty(prefix = "persistence-service", name = "migrateOnly", havingValue = "false") @ConditionalOnProperty(prefix = "persistence-service", name = "migrateOnly", havingValue = "false")
public Queue ocrDLQ() { public Queue ocrDLQ() {
return QueueBuilder.durable(OCR_DLQ) return QueueBuilder.durable(OCR_DLQ).build();
.build();
} }
@ -449,7 +448,10 @@ public class MessagingConfiguration {
@Bean @Bean
public Queue layoutparsingResponseQueue() { 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();
} }