diff --git a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/configuration/MessagingConfiguration.java b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/configuration/MessagingConfiguration.java index 2abc99f61..bdfc6b53a 100644 --- a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/configuration/MessagingConfiguration.java +++ b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/configuration/MessagingConfiguration.java @@ -48,6 +48,9 @@ public class MessagingConfiguration { public static final String PDF_2_IMAGE_RESPONSE_QUEUE = "pdf2image_response_queue"; public static final String PDF_2_IMAGE_DLQ = "pdf2image_dead_letter_queue"; + public static final String PDFTRON_QUEUE = "pdftron_queue"; + public static final String PDFTRON_RESULT_QUEUE = "pdftron_result_queue"; + @Bean public Queue nerRequestQueue() { @@ -59,10 +62,7 @@ public class MessagingConfiguration { @Bean public Queue nerResponseQueue() { - return QueueBuilder.durable(NER_SERVICE_RESPONSE_QUEUE) - .withArgument("x-dead-letter-exchange", "") - .withArgument("x-dead-letter-routing-key", NER_SERVICE_DLQ) - .build(); + return QueueBuilder.durable(NER_SERVICE_RESPONSE_QUEUE).withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", NER_SERVICE_DLQ).build(); } @@ -76,18 +76,14 @@ public class MessagingConfiguration { @Bean public Queue imageRequestQueue() { - return QueueBuilder.durable(IMAGE_SERVICE_QUEUE) - .withArgument("x-dead-letter-exchange", "") - .withArgument("x-dead-letter-routing-key", IMAGE_SERVICE_DLQ) - .build(); + return QueueBuilder.durable(IMAGE_SERVICE_QUEUE).withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", IMAGE_SERVICE_DLQ).build(); } @Bean public Queue imageResponseQueue() { - return QueueBuilder.durable(IMAGE_SERVICE_RESPONSE_QUEUE) - .withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", IMAGE_SERVICE_DLQ).build(); + return QueueBuilder.durable(IMAGE_SERVICE_RESPONSE_QUEUE).withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", IMAGE_SERVICE_DLQ).build(); } @@ -152,10 +148,7 @@ public class MessagingConfiguration { @Bean public Queue downloadQueue() { - return QueueBuilder.durable(DOWNLOAD_QUEUE) - .withArgument("x-dead-letter-exchange", "") - .withArgument("x-dead-letter-routing-key", DOWNLOAD_DLQ) - .build(); + return QueueBuilder.durable(DOWNLOAD_QUEUE).withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", DOWNLOAD_DLQ).build(); } @@ -188,10 +181,7 @@ public class MessagingConfiguration { @Bean public Queue reportResultQueue() { - return QueueBuilder.durable(REPORT_RESULT_QUEUE) - .withArgument("x-dead-letter-exchange", "") - .withArgument("x-dead-letter-routing-key", REPORT_RESULT_DLQ) - .build(); + return QueueBuilder.durable(REPORT_RESULT_QUEUE).withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", REPORT_RESULT_DLQ).build(); } @@ -205,11 +195,7 @@ public class MessagingConfiguration { @Bean public Queue indexingQueue() { - return QueueBuilder.durable(INDEXING_QUEUE) - .withArgument("x-dead-letter-exchange", "") - .withArgument("x-dead-letter-routing-key", INDEXING_DQL) - .maxPriority(2) - .build(); + return QueueBuilder.durable(INDEXING_QUEUE).withArgument("x-dead-letter-exchange", "").withArgument("x-dead-letter-routing-key", INDEXING_DQL).maxPriority(2).build(); } @@ -237,6 +223,7 @@ public class MessagingConfiguration { return QueueBuilder.durable(DELETE_FROM_INDEX_DLQ).build(); } + @Bean public Queue preprocessingQueue() { @@ -255,4 +242,17 @@ public class MessagingConfiguration { return QueueBuilder.durable(PRE_PROCESSING_DLQ).build(); } + + @Bean + public Queue pdfTronQueue() { + + return QueueBuilder.durable(PDFTRON_QUEUE).build(); + } + + @Bean + public Queue pdfTronResultQueue() { + + return QueueBuilder.durable(PDFTRON_RESULT_QUEUE).build(); + } + }