diff --git a/src/main/java/com/ecwid/consul/transport/AbstractHttpTransport.java b/src/main/java/com/ecwid/consul/transport/AbstractHttpTransport.java index 4e479fda..8444cd30 100644 --- a/src/main/java/com/ecwid/consul/transport/AbstractHttpTransport.java +++ b/src/main/java/com/ecwid/consul/transport/AbstractHttpTransport.java @@ -5,16 +5,14 @@ import org.apache.http.client.HttpClient; import org.apache.http.client.methods.*; import org.apache.http.entity.ByteArrayEntity; +import org.apache.http.entity.ContentType; import org.apache.http.entity.StringEntity; import org.apache.http.util.EntityUtils; import java.io.IOException; import java.nio.charset.StandardCharsets; -import java.util.ArrayList; -import java.util.List; import java.util.Map; import java.util.logging.Logger; -import java.util.stream.StreamSupport; public abstract class AbstractHttpTransport implements HttpTransport { @@ -41,7 +39,7 @@ public HttpResponse makePutRequest(HttpRequest request) { HttpPut httpPut = new HttpPut(request.getUrl()); addHeadersToRequest(httpPut, request.getHeaders()); if (request.getContent() != null) { - httpPut.setEntity(new StringEntity(request.getContent(), StandardCharsets.UTF_8)); + httpPut.setEntity(new StringEntity(request.getContent(), ContentType.APPLICATION_JSON)); } else { httpPut.setEntity(new ByteArrayEntity(request.getBinaryContent())); } diff --git a/src/main/java/com/ecwid/consul/v1/agent/AgentConsulClient.java b/src/main/java/com/ecwid/consul/v1/agent/AgentConsulClient.java index d4af7b2f..95fd47db 100644 --- a/src/main/java/com/ecwid/consul/v1/agent/AgentConsulClient.java +++ b/src/main/java/com/ecwid/consul/v1/agent/AgentConsulClient.java @@ -116,9 +116,9 @@ public Response agentSetMaintenance(boolean maintenanceEnabled) { @Override public Response agentSetMaintenance(boolean maintenanceEnabled, String reason) { UrlParameters maintenanceParameter = new SingleUrlParameters("enable", Boolean.toString(maintenanceEnabled)); - UrlParameters reasonParamenter = reason != null ? new SingleUrlParameters("reason", reason) : null; + UrlParameters reasonParameter = reason != null ? new SingleUrlParameters("reason", reason) : null; - HttpResponse httpResponse = rawClient.makePutRequest("/v1/agent/maintenance", "", maintenanceParameter, reasonParamenter); + HttpResponse httpResponse = rawClient.makePutRequest("/v1/agent/maintenance", "", maintenanceParameter, reasonParameter); if (httpResponse.getStatusCode() == 200) { return new Response(null, httpResponse);