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
parent a76704e0b5
commit 49bcc43716
1 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -69,6 +69,7 @@ public class MessagingConfiguration {
public static final String X_ERROR_INFO_HEADER = "x-error-message"; public static final String X_ERROR_INFO_HEADER = "x-error-message";
public static final String X_ERROR_INFO_TIMESTAMP_HEADER = "x-error-message-timestamp"; public static final String X_ERROR_INFO_TIMESTAMP_HEADER = "x-error-message-timestamp";
@Bean @Bean
public Queue nerRequestQueue() { public Queue nerRequestQueue() {
@ -321,19 +322,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();
} }
@ -343,19 +346,21 @@ public class MessagingConfiguration {
return QueueBuilder.durable(LAYOUT_PARSING_DLQ).build(); return QueueBuilder.durable(LAYOUT_PARSING_DLQ).build();
} }
@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();
} }
@ -364,4 +369,5 @@ public class MessagingConfiguration {
return QueueBuilder.durable(TABLE_EXTRACTOR_DLQ).build(); return QueueBuilder.durable(TABLE_EXTRACTOR_DLQ).build();
} }
} }