inteligr8/SearchServices
1
0
Fork 0
mirror of https://github.com/Alfresco/SearchServices.git synced 2026-09-16 18:12:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

[ SEARCH-2090 ] SolrQueueAPIClient fix

Browse Source
This commit is contained in:
agazzarini
2020-03-10 12:53:36 +01:00
parent 7bbe648979
commit 09326641f2
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
search-services/alfresco-solrclient-lib/src/main/java/org/alfresco/solr/client/SOLRAPIQueueClient.java
+2 -2
View File
@@ -102,7 +102,7 @@ public class SOLRAPIQueueClient extends SOLRAPIClient
return new AclChangeSets(
ACL_CHANGE_SET_QUEUE.stream()
.filter(aclChangeSet -> aclChangeSet.getCommitTimeMs() >= fromCommitTime && aclChangeSet.getCommitTimeMs() <= toCommitTime)
.filter(aclChangeSet -> (fromCommitTime != null && aclChangeSet.getCommitTimeMs() >= fromCommitTime) && (toCommitTime != null && aclChangeSet.getCommitTimeMs() <= toCommitTime))
.limit(maxResults)
.peek(aclChangeSet -> {
maxTime.set(Math.max(aclChangeSet.getCommitTimeMs(), maxTime.get()));
@@ -197,7 +197,7 @@ public class SOLRAPIQueueClient extends SOLRAPIClient
return new Transactions(
TRANSACTION_QUEUE.stream()
.filter(txn -> txn.getCommitTimeMs() >= fromCommitTime && txn.getCommitTimeMs() <= toCommitTime)
.filter(txn -> (fromCommitTime != null && txn.getCommitTimeMs() >= fromCommitTime) && (toCommitTime != null && txn.getCommitTimeMs() <= toCommitTime))
.limit(maxResults)
.peek(txn -> {
maxTime.set(Math.max(txn.getCommitTimeMs(), maxTime.get()));