@Test public void testConnectBasicHttpConfigurationAllOptions() throws Exception { final List<HttpHost[]> hostsConfigured = baseHostsConfigTest(ImmutableMap.<String, String>builder(). put("index." + INDEX_NAME + ".hostname", ES_HOST_01). put("index." + INDEX_NAME + ".port", String.valueOf(ES_PORT)). put("index." + INDEX_NAME + ".elasticsearch.scroll-keep-alive", String.valueOf(ES_SCROLL_KA)). put("index." + INDEX_NAME + ".elasticsearch.bulk-refresh", ES_BULK_REFRESH). put("index." + INDEX_NAME + ".elasticsearch.retry_on_conflict", String.valueOf(RETRY_ON_CONFLICT)). build()); assertNotNull(hostsConfigured); assertEquals(1, hostsConfigured.size()); HttpHost host0 = hostsConfigured.get(0)[0]; assertEquals(ES_HOST_01, host0.getHostName()); assertEquals(SCHEME_HTTP, host0.getSchemeName()); assertEquals(ES_PORT, host0.getPort()); verify(restClientSetup).getElasticSearchClient(same(restClientMock), scrollKACaptor.capture(), anyBoolean()); assertEquals(ES_SCROLL_KA, scrollKACaptor.getValue().intValue()); verify(restElasticSearchClientMock).setBulkRefresh(eq(ES_BULK_REFRESH)); verify(restElasticSearchClientMock).setRetryOnConflict(eq(RETRY_ON_CONFLICT)); }
protected RestElasticSearchClient getElasticSearchClient(RestClient rc, int scrollKeepAlive, boolean useMappingTypesForES7) { return new RestElasticSearchClient(rc, scrollKeepAlive, useMappingTypesForES7); }
RestClientSetup { protected RestElasticSearchClient getElasticSearchClient(RestClient rc, int scrollKeepAlive, boolean useMappingTypesForES7) { return new RestElasticSearchClient(rc, scrollKeepAlive, useMappingTypesForES7); } }
RestClientSetup { protected RestElasticSearchClient getElasticSearchClient(RestClient rc, int scrollKeepAlive, boolean useMappingTypesForES7) { return new RestElasticSearchClient(rc, scrollKeepAlive, useMappingTypesForES7); }  }
RestClientSetup { protected RestElasticSearchClient getElasticSearchClient(RestClient rc, int scrollKeepAlive, boolean useMappingTypesForES7) { return new RestElasticSearchClient(rc, scrollKeepAlive, useMappingTypesForES7); }  ElasticSearchClient connect(Configuration config); }
RestClientSetup { protected RestElasticSearchClient getElasticSearchClient(RestClient rc, int scrollKeepAlive, boolean useMappingTypesForES7) { return new RestElasticSearchClient(rc, scrollKeepAlive, useMappingTypesForES7); }  ElasticSearchClient connect(Configuration config);  }