IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

return types

Browse Source
This commit is contained in:
phact 2020-05-19 17:37:56 -04:00
parent 3b6b88f9a5
commit de6c6b368f
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
engine-extensions/src/main/java/io/nosqlbench/engine/extensions/http/HttpPlugin.java
View File

@ -1,7 +1,5 @@
package io.nosqlbench.engine.extensions.http; package io.nosqlbench.engine.extensions.http;
import jdk.jfr.ContentType;
import java.io.IOException; import java.io.IOException;
import java.net.URI; import java.net.URI;
import java.net.http.HttpClient; import java.net.http.HttpClient;
@ -11,7 +9,7 @@ import java.net.http.HttpResponse;
public class HttpPlugin { public class HttpPlugin {
private HttpClient client = HttpClient.newHttpClient(); private HttpClient client = HttpClient.newHttpClient();
public String get(String url) throws IOException, InterruptedException { public HttpResponse<String> get(String url) throws IOException, InterruptedException {
HttpRequest.Builder builder = HttpRequest.newBuilder(); HttpRequest.Builder builder = HttpRequest.newBuilder();
URI uri = URI.create(url); URI uri = URI.create(url);
HttpRequest request = builder HttpRequest request = builder
@ -21,14 +19,14 @@ public class HttpPlugin {
HttpResponse<String> response = client.send(request, HttpResponse<String> response = client.send(request,
HttpResponse.BodyHandlers.ofString()); HttpResponse.BodyHandlers.ofString());
return response.body(); return response;
} }
public String post(String url) throws IOException, InterruptedException { public HttpResponse<String> post(String url) throws IOException, InterruptedException {
return post(url, null, null); return post(url, null, null);
} }
public String post(String url, String data, String contentType) throws IOException, InterruptedException { public HttpResponse<String> post(String url, String data, String contentType) throws IOException, InterruptedException {
HttpRequest.Builder builder = HttpRequest.newBuilder(); HttpRequest.Builder builder = HttpRequest.newBuilder();
URI uri = URI.create(url); URI uri = URI.create(url);
@ -55,7 +53,7 @@ public class HttpPlugin {
HttpResponse<String> response = client.send(request, HttpResponse<String> response = client.send(request,
HttpResponse.BodyHandlers.ofString()); HttpResponse.BodyHandlers.ofString());
return response.body(); return response;
} }
} }