From 15cf772113dcc653f463cd403881b2613b061ef0 Mon Sep 17 00:00:00 2001 From: deiflaender Date: Wed, 28 Sep 2022 10:57:38 +0200 Subject: [PATCH] RED-5151: Fixed message deserialisation problem for downloads --- .../v1/server/service/download/DownloadMessageReceiver.java | 2 +- .../server/service/download/DownloadReportMessageReceiver.java | 2 +- .../server/service/download/RedactionResultMessageReceiver.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/DownloadMessageReceiver.java b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/DownloadMessageReceiver.java index 81ffb7b3f..7ea799461 100644 --- a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/DownloadMessageReceiver.java +++ b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/DownloadMessageReceiver.java @@ -18,7 +18,6 @@ import lombok.extern.slf4j.Slf4j; @Slf4j @Service @RequiredArgsConstructor -@RabbitListener(queues = MessagingConfiguration.DOWNLOAD_QUEUE) public class DownloadMessageReceiver { private final DownloadProcessorService downloadProcessorService; @@ -27,6 +26,7 @@ public class DownloadMessageReceiver { @SneakyThrows @RabbitHandler + @RabbitListener(queues = MessagingConfiguration.DOWNLOAD_QUEUE) public void receive(Message message) throws JsonProcessingException { DownloadJob downloadJob = objectMapper.readValue(message.getBody(), DownloadJob.class); diff --git a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/DownloadReportMessageReceiver.java b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/DownloadReportMessageReceiver.java index 97d246c7b..e2b24366f 100644 --- a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/DownloadReportMessageReceiver.java +++ b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/DownloadReportMessageReceiver.java @@ -20,7 +20,6 @@ import lombok.extern.slf4j.Slf4j; @Slf4j @Service @RequiredArgsConstructor -@RabbitListener(queues = MessagingConfiguration.REPORT_RESULT_QUEUE) @FieldDefaults(level = AccessLevel.PRIVATE, makeFinal = true) public class DownloadReportMessageReceiver { @@ -30,6 +29,7 @@ public class DownloadReportMessageReceiver { @SneakyThrows @RabbitHandler + @RabbitListener(queues = MessagingConfiguration.REPORT_RESULT_QUEUE) public void receive(Message message){ ReportResultMessage reportResultMessage = objectMapper.readValue(message.getBody(), ReportResultMessage.class); diff --git a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/RedactionResultMessageReceiver.java b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/RedactionResultMessageReceiver.java index b532467ff..6fbd29b41 100644 --- a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/RedactionResultMessageReceiver.java +++ b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/RedactionResultMessageReceiver.java @@ -21,7 +21,6 @@ import lombok.extern.slf4j.Slf4j; @Service @RequiredArgsConstructor @FieldDefaults(level = AccessLevel.PRIVATE, makeFinal = true) -@RabbitListener(queues = MessagingConfiguration.PDFTRON_RESULT_QUEUE) public class RedactionResultMessageReceiver { ObjectMapper objectMapper; @@ -30,6 +29,7 @@ public class RedactionResultMessageReceiver { @SneakyThrows @RabbitHandler + @RabbitListener(queues = MessagingConfiguration.PDFTRON_RESULT_QUEUE) public void receive(Message message) throws JsonProcessingException { RedactionResultMessage redactionResultMessage = objectMapper.readValue(message.getBody(), RedactionResultMessage.class);