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 ma...@apache.org on 2018/06/06 07:00:59 UTC
[05/15] james-project git commit: JAMES-2408 DeleteByQueryPerformer:
should rely on a Write Alias
JAMES-2408 DeleteByQueryPerformer: should rely on a Write Alias
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo
Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/86a4395b
Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/86a4395b
Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/86a4395b
Branch: refs/heads/master
Commit: 86a4395bd3dd5e390be5376ca09a4d0245bafd75
Parents: 6033c3f
Author: benwa <bt...@linagora.com>
Authored: Tue Jun 5 14:41:39 2018 +0700
Committer: Matthieu Baechler <ma...@apache.org>
Committed: Wed Jun 6 08:58:57 2018 +0200
----------------------------------------------------------------------
.../org/apache/james/backends/es/DeleteByQueryPerformer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/james-project/blob/86a4395b/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 5fbd7b3..b465f96 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
@@ -40,11 +40,11 @@ public class DeleteByQueryPerformer {
private final Client client;
private final ExecutorService executor;
private final int batchSize;
- private final AliasName aliasName;
+ private final WriteAliasName aliasName;
private final TypeName typeName;
@VisibleForTesting
- public DeleteByQueryPerformer(Client client, ExecutorService executor, int batchSize, AliasName aliasName, TypeName typeName) {
+ public DeleteByQueryPerformer(Client client, ExecutorService executor, int batchSize, WriteAliasName aliasName, TypeName typeName) {
this.client = client;
this.executor = executor;
this.batchSize = batchSize;
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org