diff options
| author | Luca Cavanna <javanna@users.noreply.github.com> | 2017-05-03 11:20:53 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-05-03 11:20:53 +0200 |
| commit | 92bfd16c5824885ca673c5bb99acac9148c18693 (patch) | |
| tree | e78cded3ebf92d44d5fef49228ea7703f7590a6e /core/src/test/java/org/elasticsearch/action/support | |
| parent | be19ccef573b4e9a839159157d7e6c2645261897 (diff) | |
Java api: ActionRequestBuilder#execute to return a PlainActionFuture (#24415)
This change makes the request builder code-path same as `Client#execute`. The request builder used to return a `ListenableActionFuture` when calling execute, which allows to associate listeners with the returned future. For async execution though it is recommended to use the `execute` method that accepts an `ActionListener`, like users would do when using `Client#execute`.
Relates to #24412
Relates to #9201
Diffstat (limited to 'core/src/test/java/org/elasticsearch/action/support')
| -rw-r--r-- | core/src/test/java/org/elasticsearch/action/support/ActiveShardsObserverIT.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/test/java/org/elasticsearch/action/support/ActiveShardsObserverIT.java b/core/src/test/java/org/elasticsearch/action/support/ActiveShardsObserverIT.java index 5f52293d7e..f3611663b4 100644 --- a/core/src/test/java/org/elasticsearch/action/support/ActiveShardsObserverIT.java +++ b/core/src/test/java/org/elasticsearch/action/support/ActiveShardsObserverIT.java @@ -19,7 +19,7 @@ package org.elasticsearch.action.support; -import org.elasticsearch.action.ListenableActionFuture; +import org.elasticsearch.action.ActionFuture; import org.elasticsearch.action.admin.indices.create.CreateIndexResponse; import org.elasticsearch.common.Priority; import org.elasticsearch.common.settings.Settings; @@ -140,7 +140,7 @@ public class ActiveShardsObserverIT extends ESIntegTestCase { .build(); logger.info("--> start the index creation process"); - ListenableActionFuture<CreateIndexResponse> responseListener = + ActionFuture<CreateIndexResponse> responseListener = prepareCreate(indexName) .setSettings(settings) .setWaitForActiveShards(ActiveShardCount.ALL) |