[MNT-22353]- Added Streams for filtering frozen nodes.

This commit is contained in:
pjoshi31
2022-11-02 18:05:11 +05:30
parent a361596512
commit 3f10227c0f

View File

@@ -217,7 +217,7 @@ public class DispositionLifecycleJobExecuter extends RecordsManagementJobExecute
ResultSet results = searchService.query(params);
hasMore = results.hasMore();
if(results.length() != 0) {
resultList=results.getNodeRefs().parallelStream().filter(node ->!freezeService.isFrozenOrHasFrozenChildren(nodeService.getPrimaryParent(node).getParentRef())).collect(Collectors.toList());
resultList=results.getNodeRefs().stream().filter(node ->!freezeService.isFrozenOrHasFrozenChildren(nodeService.getPrimaryParent(node).getParentRef())).collect(Collectors.toList());
}
skipCount += resultList.size(); // increase by page size
results.close();