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

Merge remote-tracking branch 'origin/RED-7375' into RED-7375

Browse Source 
# Conflicts:
#	persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/configuration/MessagingConfiguration.java
This commit is contained in:
yhampe 2024-01-16 10:10:53 +01:00
commit 3feccd8128
1 changed files with 4 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -69,34 +69,6 @@ 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";
// --- Saas Migration, can be removed later ----
public static final String MIGRATION_QUEUE = "migrationQueue";
public static final String MIGRATION_DLQ = "migrationDLQ";
public static final String MIGRATION_RESPONSE_QUEUE = "migrationResponseQueue";
@Bean
public Queue migrationQueue() {
return QueueBuilder.durable(MIGRATION_QUEUE).withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", MIGRATION_DLQ).maxPriority(2).build();
}
@Bean
public Queue migrationDLQ() {
return QueueBuilder.durable(MIGRATION_DLQ).build();
}
@Bean
public Queue migrationResponseQueue() {
return QueueBuilder.durable(MIGRATION_RESPONSE_QUEUE).withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", MIGRATION_DLQ).maxPriority(2).build();
}
// --- End Saas Migration
@Bean @Bean
public Queue nerRequestQueue() { public Queue nerRequestQueue() {
@ -354,7 +326,8 @@ public class MessagingConfiguration {
@Bean @Bean
public Queue layoutparsingRequestQueue() { public Queue layoutparsingRequestQueue() {
return QueueBuilder.durable(LAYOUT_PARSING_REQUEST_QUEUE).withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", LAYOUT_PARSING_DLQ).build(); return QueueBuilder.durable(LAYOUT_PARSING_REQUEST_QUEUE)//
.withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", LAYOUT_PARSING_DLQ).build();
} }
@ -374,6 +347,7 @@ 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() {
@ -396,4 +370,5 @@ public class MessagingConfiguration {
return QueueBuilder.durable(TABLE_EXTRACTOR_DLQ).build(); return QueueBuilder.durable(TABLE_EXTRACTOR_DLQ).build();
} }
} }