diff --git a/client/rest/src/test/java/org/elasticsearch/client/RestClientSingleHostIntegTests.java b/client/rest/src/test/java/org/elasticsearch/client/RestClientSingleHostIntegTests.java index 3f57e8c391215..5979c508de287 100644 --- a/client/rest/src/test/java/org/elasticsearch/client/RestClientSingleHostIntegTests.java +++ b/client/rest/src/test/java/org/elasticsearch/client/RestClientSingleHostIntegTests.java @@ -35,7 +35,9 @@ import org.apache.http.nio.entity.NStringEntity; import org.apache.http.util.EntityUtils; import org.elasticsearch.mocksocket.MockHttpServer; +import org.junit.After; import org.junit.AfterClass; +import org.junit.Before; import org.junit.BeforeClass; import java.io.IOException; @@ -69,20 +71,20 @@ */ public class RestClientSingleHostIntegTests extends RestClientTestCase { - private static HttpServer httpServer; - private static RestClient restClient; - private static String pathPrefix; - private static Header[] defaultHeaders; + private HttpServer httpServer; + private RestClient restClient; + private String pathPrefix; + private Header[] defaultHeaders; - @BeforeClass - public static void startHttpServer() throws Exception { + @Before + public void startHttpServer() throws Exception { pathPrefix = randomBoolean() ? "/testPathPrefix/" + randomAsciiLettersOfLengthBetween(1, 5) : ""; httpServer = createHttpServer(); defaultHeaders = RestClientTestUtil.randomHeaders(getRandom(), "Header-default"); restClient = createRestClient(false, true); } - private static HttpServer createHttpServer() throws Exception { + private HttpServer createHttpServer() throws Exception { HttpServer httpServer = MockHttpServer.createHttp(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), 0); httpServer.start(); //returns a different status code depending on the path @@ -127,7 +129,7 @@ public void handle(HttpExchange httpExchange) throws IOException { } } - private static RestClient createRestClient(final boolean useAuth, final boolean usePreemptiveAuth) { + private RestClient createRestClient(final boolean useAuth, final boolean usePreemptiveAuth) { // provide the username/password for every request final BasicCredentialsProvider credentialsProvider = new BasicCredentialsProvider(); credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("user", "pass")); @@ -155,8 +157,8 @@ public HttpAsyncClientBuilder customizeHttpClient(final HttpAsyncClientBuilder h return restClientBuilder.build(); } - @AfterClass - public static void stopHttpServers() throws IOException { + @After + public void stopHttpServers() throws IOException { restClient.close(); restClient = null; httpServer.stop(0);