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 aaa379f93..111edded4 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 @@ -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_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 public Queue nerRequestQueue() { @@ -354,7 +326,8 @@ public class MessagingConfiguration { @Bean 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(); } + @Bean public Queue tableExtractorRequestQueue() { @@ -396,4 +370,5 @@ public class MessagingConfiguration { return QueueBuilder.durable(TABLE_EXTRACTOR_DLQ).build(); } + }