From 11958a4099ae3e095b61deee7e15c78f8cae44f4 Mon Sep 17 00:00:00 2001 From: Corina Olariu Date: Thu, 17 Aug 2023 16:50:09 +0300 Subject: [PATCH] RED-6864 - Optimization of Upload and Download for Large Files in Azure Blob Storage and AWS S3/MinIO - add @RabbitListener to the method --- .../processor/service/download/RedactionDlqMessageReceiver.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/download/RedactionDlqMessageReceiver.java b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/download/RedactionDlqMessageReceiver.java index f6a480a1c..eac320b1b 100644 --- a/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/download/RedactionDlqMessageReceiver.java +++ b/persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/download/RedactionDlqMessageReceiver.java @@ -23,7 +23,6 @@ import lombok.extern.slf4j.Slf4j; @Service @RequiredArgsConstructor @FieldDefaults(level = AccessLevel.PRIVATE, makeFinal = true) -@RabbitListener(queues = MessagingConfiguration.PDFTRON_DLQ) public class RedactionDlqMessageReceiver { private static final String LINE_SEPARATOR = System.lineSeparator(); @@ -34,6 +33,7 @@ public class RedactionDlqMessageReceiver { @RabbitHandler + @RabbitListener(queues = MessagingConfiguration.PDFTRON_DLQ) public void receive(Message message) throws IOException { // Since we receive different message types here, we do not convert to an object here;