diff options
| author | Nik Everett <nik9000@gmail.com> | 2016-06-06 13:18:32 -0400 |
|---|---|---|
| committer | Nik Everett <nik9000@gmail.com> | 2016-06-08 13:50:59 -0400 |
| commit | 4b211579065487120f33b1b23cd5a91419993df0 (patch) | |
| tree | a6884595da5720ca26fcb6ecf87aa17d3e4a1dfb /core/src/test/java/org/elasticsearch/mget | |
| parent | 92349f70e22894b08000636b4d8a48c1d93782c6 (diff) | |
Remove setRefresh
It has been replaced with `setRefreshPolicy` which has support for
waiting until refresh with `setRefreshPolicy(WAIT_FOR)`.
Related to #1063
Diffstat (limited to 'core/src/test/java/org/elasticsearch/mget')
| -rw-r--r-- | core/src/test/java/org/elasticsearch/mget/SimpleMgetIT.java | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/core/src/test/java/org/elasticsearch/mget/SimpleMgetIT.java b/core/src/test/java/org/elasticsearch/mget/SimpleMgetIT.java index 21be585862..e710186969 100644 --- a/core/src/test/java/org/elasticsearch/mget/SimpleMgetIT.java +++ b/core/src/test/java/org/elasticsearch/mget/SimpleMgetIT.java @@ -33,6 +33,7 @@ import org.elasticsearch.test.ESIntegTestCase; import java.io.IOException; import java.util.Map; +import static org.elasticsearch.action.support.WriteRequest.RefreshPolicy.IMMEDIATE; import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder; import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertAcked; import static org.hamcrest.Matchers.equalTo; @@ -45,7 +46,8 @@ public class SimpleMgetIT extends ESIntegTestCase { createIndex("test"); ensureYellow(); - client().prepareIndex("test", "test", "1").setSource(jsonBuilder().startObject().field("foo", "bar").endObject()).setRefresh(true).execute().actionGet(); + client().prepareIndex("test", "test", "1").setSource(jsonBuilder().startObject().field("foo", "bar").endObject()) + .setRefreshPolicy(IMMEDIATE).get(); MultiGetResponse mgetResponse = client().prepareMultiGet() .add(new MultiGetRequest.Item("test", "test", "1")) @@ -86,9 +88,9 @@ public class SimpleMgetIT extends ESIntegTestCase { .endObject())); ensureYellow(); - client().prepareIndex("test", "test", "1").setParent("4").setRefresh(true) + client().prepareIndex("test", "test", "1").setParent("4").setRefreshPolicy(IMMEDIATE) .setSource(jsonBuilder().startObject().field("foo", "bar").endObject()) - .execute().actionGet(); + .get(); MultiGetResponse mgetResponse = client().prepareMultiGet() .add(new MultiGetRequest.Item(indexOrAlias(), "test", "1").parent("4")) @@ -154,9 +156,9 @@ public class SimpleMgetIT extends ESIntegTestCase { final String id = routingKeyForShard("test", "test", 0); final String routingOtherShard = routingKeyForShard("test", "test", 1); - client().prepareIndex("test", "test", id).setRefresh(true).setRouting(routingOtherShard) + client().prepareIndex("test", "test", id).setRefreshPolicy(IMMEDIATE).setRouting(routingOtherShard) .setSource(jsonBuilder().startObject().field("foo", "bar").endObject()) - .execute().actionGet(); + .get(); MultiGetResponse mgetResponse = client().prepareMultiGet() .add(new MultiGetRequest.Item(indexOrAlias(), "test", id).routing(routingOtherShard)) |