diff --git a/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/queue/RedactionMessageReceiver.java b/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/queue/RedactionMessageReceiver.java index 91f04d84..cea10030 100644 --- a/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/queue/RedactionMessageReceiver.java +++ b/redaction-service-v1/redaction-service-server-v1/src/main/java/com/iqser/red/service/redaction/v1/server/queue/RedactionMessageReceiver.java @@ -73,6 +73,7 @@ public class RedactionMessageReceiver { log.info("Processing AnalyzeRequest for file: {}, priority: {} ", analyzeRequest.getFileId(), priority); log.info(""); AnalyzeResult result = new AnalyzeResult(); + boolean shouldRespond = true; try { switch (analyzeRequest.getMessageType()) { @@ -103,20 +104,23 @@ public class RedactionMessageReceiver { case SURROUNDING_TEXT_ANALYSIS: log.info("------------------------------Surrounding Text Analysis------------------------------------------"); log.info("Starting Surrounding Text Analysis for file {} in dossier {}", analyzeRequest.getFileId(), analyzeRequest.getDossierId()); - log.info(analyzeRequest.getManualRedactions().toString()); + log.debug(analyzeRequest.getManualRedactions().toString()); unprocessedChangesService.analyseSurroundingText(analyzeRequest); log.info("Successful Surrounding Text Analysis dossier {} file {} ", analyzeRequest.getDossierId(), analyzeRequest.getFileId()); log.info("-------------------------------------------------------------------------------------------------"); + shouldRespond = false; break; default: throw new IllegalArgumentException("Unknown MessageType: " + analyzeRequest.getMessageType()); } log.info(""); - result.setMessageType(analyzeRequest.getMessageType()); - fileStatusProcessingUpdateClient.analysisSuccessful(analyzeRequest.getDossierId(), analyzeRequest.getFileId(), result); + if (shouldRespond) { + result.setMessageType(analyzeRequest.getMessageType()); + fileStatusProcessingUpdateClient.analysisSuccessful(analyzeRequest.getDossierId(), analyzeRequest.getFileId(), result); + } } catch (DroolsTimeoutException droolsTimeoutException) { if (!droolsTimeoutException.isReported()) { rulesClient.setRulesTimeoutDetected(analyzeRequest.getDossierTemplateId(), droolsTimeoutException.getRuleFileType());