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 <btell...@linagora.com> Authored: Tue Jun 5 14:41:39 2018 +0700 Committer: Matthieu Baechler <matth...@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-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
