diff --git a/ocr-service-v1/ocr-service-processor/src/main/java/com/knecon/fforesight/service/ocr/processor/service/threads/ImageProcessingThread.java b/ocr-service-v1/ocr-service-processor/src/main/java/com/knecon/fforesight/service/ocr/processor/service/threads/ImageProcessingThread.java index d0149c9..c7a81e9 100644 --- a/ocr-service-v1/ocr-service-processor/src/main/java/com/knecon/fforesight/service/ocr/processor/service/threads/ImageProcessingThread.java +++ b/ocr-service-v1/ocr-service-processor/src/main/java/com/knecon/fforesight/service/ocr/processor/service/threads/ImageProcessingThread.java @@ -61,7 +61,11 @@ public class ImageProcessingThread extends Thread { while (!allImagesExtracted) { final UnprocessedImage image = imageInputQueue.take(); var ocrImage = this.process(image); - imageOutputQueue.put(ocrImage); + try { + imageOutputQueue.put(ocrImage); + } catch (InterruptedException e) { + imageOutputQueue.put(ocrImage); + } } } catch (InterruptedException e) { log.info("All images extracted, emptying processing queue and stopping");