You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2018/05/30 02:24:23 UTC
[12/14] james-project git commit: JAMES-2404 Fix unstable test
JAMES-2404 Fix unstable test
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo
Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/33e94d69
Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/33e94d69
Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/33e94d69
Branch: refs/heads/master
Commit: 33e94d69d6821ba02c8a18a0cc61399c0edc2bce
Parents: a7997fe
Author: Antoine Duprat <ad...@linagora.com>
Authored: Mon May 28 14:41:10 2018 +0200
Committer: Antoine Duprat <ad...@linagora.com>
Committed: Tue May 29 15:32:53 2018 +0200
----------------------------------------------------------------------
.../java/org/apache/james/backends/es/DeleteByQueryPerformer.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/james-project/blob/33e94d69/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/DeleteByQueryPerformer.java
----------------------------------------------------------------------
diff --git a/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/DeleteByQueryPerformer.java b/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/DeleteByQueryPerformer.java
index a267b3a..024511b 100644
--- a/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/DeleteByQueryPerformer.java
+++ b/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/DeleteByQueryPerformer.java
@@ -70,7 +70,8 @@ public class DeleteByQueryPerformer {
.setQuery(queryBuilder)
.setSize(batchSize))
.stream()
- .forEach(searchResponse -> deleteRetrievedIds(client, searchResponse));
+ .map(searchResponse -> deleteRetrievedIds(client, searchResponse))
+ .forEach(ListenableActionFuture::actionGet);
}
private ListenableActionFuture<BulkResponse> deleteRetrievedIds(Client client, SearchResponse searchResponse) {
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org