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

RED-5151: Fixed message deserialisation problem for downloads

Browse Source
This commit is contained in:
deiflaender 2022-09-28 10:57:38 +02:00
parent d56e2dc058
commit 15cf772113
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/DownloadMessageReceiver.java
View File

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

2
persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/DownloadReportMessageReceiver.java
View File

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

2
persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/download/RedactionResultMessageReceiver.java
View File

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