diff --git a/ocr-service-v1/ocr-service-server-v1/src/main/java/com/iqser/red/service/ocr/v1/server/service/OcrMessageReceiver.java b/ocr-service-v1/ocr-service-server-v1/src/main/java/com/iqser/red/service/ocr/v1/server/service/OcrMessageReceiver.java index 1683ae1..6452d50 100644 --- a/ocr-service-v1/ocr-service-server-v1/src/main/java/com/iqser/red/service/ocr/v1/server/service/OcrMessageReceiver.java +++ b/ocr-service-v1/ocr-service-server-v1/src/main/java/com/iqser/red/service/ocr/v1/server/service/OcrMessageReceiver.java @@ -15,6 +15,8 @@ import com.fasterxml.jackson.databind.ObjectMapper; import com.iqser.red.service.ocr.v1.api.model.DocumentRequest; import com.iqser.red.service.ocr.v1.server.client.FileStatusProcessingUpdateClient; import com.iqser.red.service.ocr.v1.server.configuration.MessagingConfiguration; +import com.iqser.red.service.ocr.v1.server.initializer.PDFNetInitializer; +import com.pdftron.pdf.PDFNet; import feign.FeignException; import lombok.RequiredArgsConstructor; @@ -28,6 +30,7 @@ public class OcrMessageReceiver { private final ObjectMapper objectMapper; private final FileStorageService fileStorageService; private final FileStatusProcessingUpdateClient fileStatusProcessingUpdateClient; + private final PDFNetInitializer pdfNetInitializer; private final OCRService ocrService; @@ -36,6 +39,7 @@ public class OcrMessageReceiver { @RabbitListener(queues = MessagingConfiguration.OCR_QUEUE, concurrency = "1") public void receiveOcr(String in) throws JsonProcessingException { + pdfNetInitializer.init(); DocumentRequest ocrRequestMessage = objectMapper.readValue(in, DocumentRequest.class); log.info("Start ocr for file with dossierId {} and fileId {}", ocrRequestMessage.getDossierId(), ocrRequestMessage.getFileId()); @@ -58,6 +62,7 @@ public class OcrMessageReceiver { } fileStatusProcessingUpdateClient.ocrSuccessful(ocrRequestMessage.getDossierId(), ocrRequestMessage.getFileId()); + PDFNet.terminate(); }