diff --git a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/job/AutomaticAnalysisJob.java b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/job/AutomaticAnalysisJob.java index 9cdb20c7d..ff3bd9347 100644 --- a/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/job/AutomaticAnalysisJob.java +++ b/persistence-service-v1/persistence-service-server-v1/src/main/java/com/iqser/red/service/peristence/v1/server/service/job/AutomaticAnalysisJob.java @@ -12,6 +12,8 @@ import org.springframework.amqp.core.AmqpAdmin; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import java.util.Collections; +import java.util.Comparator; import java.util.List; @Slf4j @@ -42,6 +44,9 @@ public class AutomaticAnalysisJob implements Job { if (redactionQueueInfo.getMessageCount() <= consumerCount) { // queue up 5 files var allStatuses = getAllRelevantStatuses(); + + allStatuses.sort(Collections.reverseOrder(Comparator.comparing(FileModel::getLastUpdated))); + var allStatusesIterator = allStatuses.iterator(); log.info("Files that require reanalysis: {}", allStatuses.size());