@@ -243,7 +243,7 @@ public <Result, Body> Request getHttpRequest(final IHttpRequest request,
243243 if (this .connectionConfig == null ) {
244244 this .connectionConfig = new DefaultConnectionConfig ();
245245 }
246-
246+
247247 // Request level middleware options
248248 RedirectOptions redirectOptions = new RedirectOptions (request .getMaxRedirects () > 0 ? request .getMaxRedirects () : this .connectionConfig .getMaxRedirects (),
249249 request .getShouldRedirect () != null ? request .getShouldRedirect () : this .connectionConfig .getShouldRedirect ());
@@ -256,7 +256,7 @@ public <Result, Body> Request getHttpRequest(final IHttpRequest request,
256256 .newBuilder ()
257257 .tag (RedirectOptions .class , redirectOptions )
258258 .tag (RetryOptions .class , retryOptions );
259-
259+
260260 String contenttype = null ;
261261
262262 logger .logDebug ("Request Method " + request .getHttpMethod ().toString ());
@@ -276,11 +276,7 @@ public <Result, Body> Request getHttpRequest(final IHttpRequest request,
276276 // This ensures that the Content-Length header is properly set
277277 if (request .getHttpMethod () == HttpMethod .POST ) {
278278 bytesToWrite = new byte [0 ];
279- if (contenttype == null ) {
280- contenttype = Constants .BINARY_CONTENT_TYPE ;
281- }
282- }
283- else {
279+ } else {
284280 bytesToWrite = null ;
285281 }
286282 } else if (serializable instanceof byte []) {
@@ -341,7 +337,11 @@ public void writeTo(BufferedSink sink) throws IOException {
341337
342338 @ Override
343339 public MediaType contentType () {
344- return MediaType .parse (mediaContentType );
340+ if (mediaContentType == null || mediaContentType .isEmpty ()) {
341+ return null ;
342+ } else {
343+ return MediaType .parse (mediaContentType );
344+ }
345345 }
346346 };
347347 }
@@ -401,7 +401,7 @@ public Request authenticateRequest(Request request) {
401401 try {
402402
403403 // Call being executed
404-
404+
405405
406406 if (handler != null ) {
407407 handler .configConnection (response );
@@ -425,7 +425,7 @@ public Request authenticateRequest(Request request) {
425425
426426 if (response .code () == HttpResponseCode .HTTP_NOBODY
427427 || response .code () == HttpResponseCode .HTTP_NOT_MODIFIED ) {
428- logger .logDebug ("Handling response with no body" );
428+ logger .logDebug ("Handling response with no body" );
429429 return handleEmptyResponse (responseHeadersHelper .getResponseHeadersAsMapOfStringList (response ), resultClass );
430430 }
431431
@@ -442,7 +442,7 @@ public Request authenticateRequest(Request request) {
442442 return (Result ) null ;
443443
444444 final String contentType = headers .get (Constants .CONTENT_TYPE_HEADER_NAME );
445- if (contentType != null && resultClass != InputStream .class &&
445+ if (contentType != null && resultClass != InputStream .class &&
446446 contentType .contains (Constants .JSON_CONTENT_TYPE )) {
447447 logger .logDebug ("Response json" );
448448 return handleJsonResponse (in , responseHeadersHelper .getResponseHeadersAsMapOfStringList (response ), resultClass );
@@ -534,12 +534,12 @@ private <Result> Result handleJsonResponse(final InputStream in, Map<String, Lis
534534
535535 /**
536536 * Handles the case where the response body is empty
537- *
537+ *
538538 * @param responseHeaders the response headers
539539 * @param clazz the type of the response object
540540 * @return the JSON object
541541 */
542- private <Result > Result handleEmptyResponse (Map <String , List <String >> responseHeaders , final Class <Result > clazz )
542+ private <Result > Result handleEmptyResponse (Map <String , List <String >> responseHeaders , final Class <Result > clazz )
543543 throws UnsupportedEncodingException {
544544 //Create an empty object to attach the response headers to
545545 InputStream in = new ByteArrayInputStream ("{}" .getBytes (Constants .JSON_ENCODING ));
0 commit comments