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

Pull request #539: RED-5151: Fixed message deserialisation problem for downloads

Browse Source 
Merge in RED/persistence-service from RED-5151 to master

* commit '15cf772113dcc653f463cd403881b2613b061ef0':
  RED-5151: Fixed message deserialisation problem for downloads
This commit is contained in:
Dominique Eiflaender 2022-09-28 11:21:55 +02:00
commit 3071a0efeb
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);