From dc047675f17bd3f3562f837354f0b031ef586b74 Mon Sep 17 00:00:00 2001 From: Timo Bejan Date: Thu, 7 Oct 2021 11:22:17 +0300 Subject: [PATCH] upgraded persistence service --- .../service/scheduler/AutomaticAnalysisScheduler.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/scheduler/AutomaticAnalysisScheduler.java b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/scheduler/AutomaticAnalysisScheduler.java index 9ba5347dd..c59d22c3e 100644 --- a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/scheduler/AutomaticAnalysisScheduler.java +++ b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/scheduler/AutomaticAnalysisScheduler.java @@ -41,12 +41,13 @@ public class AutomaticAnalysisScheduler { // only 1 file in queue if (redactionQueueInfo.getMessageCount() <= 1) { // queue up 5 files - var allStatuses = getAllStatuses().iterator(); + var allStatuses= getAllStatuses(); + var allStatusesIterator = allStatuses.iterator(); int queuedCount = 0; - log.info("Files that require reanalysis: {}", allStatuses); + log.info("Files that require reanalysis: {}", allStatuses.size()); - while (queuedCount < 5 && allStatuses.hasNext()) { - var next = allStatuses.next(); + while (queuedCount < 5 && allStatusesIterator.hasNext()) { + var next = allStatusesIterator.next(); if (next.isAnalysisRequired()) { queuedCount += 1; log.info("Queued file: {} for automatic analysis!", next.getFilename());