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

RED-7375: integrate table extractor

Browse Source 
* bind the correct DLQ
This commit is contained in:
Kilian Schuettler 2023-08-31 17:25:49 +02:00 committed by yhampe
parent e4184e442b
commit 836eea7829
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -350,19 +350,21 @@ public class MessagingConfiguration {
.build(); .build();
} }
@Bean @Bean
public Queue layoutparsingRequestQueue() { public Queue layoutparsingRequestQueue() {
return QueueBuilder.durable(LAYOUT_PARSING_REQUEST_QUEUE)// return QueueBuilder.durable(LAYOUT_PARSING_REQUEST_QUEUE).withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", LAYOUT_PARSING_DLQ).build();
.withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", LAYOUT_PARSING_DLQ).build();
} }
@Bean @Bean
public Queue layoutparsingResponseQueue() { public Queue layoutparsingResponseQueue() {
return QueueBuilder.durable(LAYOUT_PARSING_FINISHED_EVENT_QUEUE)// return QueueBuilder.durable(LAYOUT_PARSING_FINISHED_EVENT_QUEUE)
.withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", LAYOUT_PARSING_DLQ).build(); .withArgument("x-dead-letter-exchange", "")
.withArgument("x-dead-letter-routing-key", LAYOUT_PARSING_DLQ)
.build();
} }
@ -375,16 +377,17 @@ public class MessagingConfiguration {
@Bean @Bean
public Queue tableExtractorRequestQueue() { public Queue tableExtractorRequestQueue() {
return QueueBuilder.durable(TABLE_EXTRACTOR_QUEUE)// return QueueBuilder.durable(TABLE_EXTRACTOR_QUEUE).withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", TABLE_EXTRACTOR_DLQ).build();
.withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", LAYOUT_PARSING_DLQ).build();
} }
@Bean @Bean
public Queue tableExtractorResponseQueue() { public Queue tableExtractorResponseQueue() {
return QueueBuilder.durable(TABLE_EXTRACTOR_RESPONSE_QUEUE)// return QueueBuilder.durable(TABLE_EXTRACTOR_RESPONSE_QUEUE)
.withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", LAYOUT_PARSING_DLQ).build(); .withArgument("x-dead-letter-exchange", "")
.withArgument("x-dead-letter-routing-key", TABLE_EXTRACTOR_DLQ)
.build();
} }