From a5977fedb2b264c8c398b65806d5cbaabdca8bc7 Mon Sep 17 00:00:00 2001 From: pjoshi31 Date: Mon, 7 Nov 2022 12:19:27 +0530 Subject: [PATCH] [MNT-22353]- Removed length condition. --- .../job/DispositionLifecycleJobExecuter.java | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/amps/ags/rm-community/rm-community-repo/source/java/org/alfresco/module/org_alfresco_module_rm/job/DispositionLifecycleJobExecuter.java b/amps/ags/rm-community/rm-community-repo/source/java/org/alfresco/module/org_alfresco_module_rm/job/DispositionLifecycleJobExecuter.java index b9481d2178..d98f5e0340 100644 --- a/amps/ags/rm-community/rm-community-repo/source/java/org/alfresco/module/org_alfresco_module_rm/job/DispositionLifecycleJobExecuter.java +++ b/amps/ags/rm-community/rm-community-repo/source/java/org/alfresco/module/org_alfresco_module_rm/job/DispositionLifecycleJobExecuter.java @@ -204,8 +204,7 @@ public class DispositionLifecycleJobExecuter extends RecordsManagementJobExecute log.trace("Using batch size of " + batchSize); - while (hasMore) - { + while (hasMore) { SearchParameters params = new SearchParameters(); params.addStore(StoreRef.STORE_REF_WORKSPACE_SPACESSTORE); params.setLanguage(SearchService.LANGUAGE_FTS_ALFRESCO); @@ -215,11 +214,9 @@ public class DispositionLifecycleJobExecuter extends RecordsManagementJobExecute // execute search ResultSet results = searchService.query(params); + // filtering out the hold/freezed cases from the result set + resultNodes = results.getNodeRefs().stream().filter(node -> !freezeService.isFrozenOrHasFrozenChildren(node)).collect(Collectors.toList()); hasMore = results.hasMore(); - if(results.length() != 0) { - // filtering out the hold/freezed cases from the result set - resultNodes=results.getNodeRefs().stream().filter(node ->!freezeService.isFrozenOrHasFrozenChildren(nodeService.getPrimaryParent(node).getParentRef())).collect(Collectors.toList()); - } skipCount += resultNodes.size(); // increase by page size results.close();