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;