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

RED-1098: Added configuration for the pdftron-redaction queue's

Browse Source
This commit is contained in:
Viktor Seifert 2022-06-23 17:29:16 +02:00
parent 71a34f58a2
commit 6a5da764b5
1 changed files with 23 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/configuration/MessagingConfiguration.java
View File

@ -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();
}
}