dapr
/
java-sdk
mirror of https://github.com/dapr/java-sdk.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

closed the response objects and returning a string (#56)

This commit is contained in:
ji11er 2019-12-19 23:47:25 +01:00 committed by Artur Souza
parent 9a10a960e8
commit 4bd9942b8c
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
sdk/src/main/java/io/dapr/actors/AbstractDaprClient.java
View File

@ -1,3 +1,7 @@
/*
* Copyright (c) Microsoft Corporation.
* Licensed under the MIT License.
*/
package io.dapr.actors; package io.dapr.actors;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
@ -90,7 +94,7 @@ public abstract class AbstractDaprClient {
} }
/** /**
* Invokes an API synchronously and returns a text payload. * Invokes an API asynchronously and returns a text payload.
* *
* @param method HTTP method. * @param method HTTP method.
* @param urlString url as String. * @param urlString url as String.
@ -108,6 +112,7 @@ public abstract class AbstractDaprClient {
.build(); .build();
this.httpClient.newCall(request).enqueue(new Callback() { this.httpClient.newCall(request).enqueue(new Callback() {
@Override @Override
public void onFailure(Call call, IOException e) { public void onFailure(Call call, IOException e) {
cb.onFailure(call, e); cb.onFailure(call, e);
@ -118,11 +123,14 @@ public abstract class AbstractDaprClient {
try (ResponseBody responseBody = response.body()) { try (ResponseBody responseBody = response.body()) {
if (!response.isSuccessful()) { if (!response.isSuccessful()) {
DaprError error = parseDaprError(response.body().string()); DaprError error = parseDaprError(response.body().string());
response.close();
if ((error != null) && (error.getErrorCode() != null) && (error.getMessage() != null)) { if ((error != null) && (error.getErrorCode() != null) && (error.getMessage() != null)) {
throw new DaprException(error); throw new DaprException(error);
} }
} else { } else {
cb.onSuccess(responseBody.toString()); String respBodyString = responseBody.string();
cb.onSuccess(respBodyString);
response.close();
} }
} }
} }
@ -155,10 +163,10 @@ public abstract class AbstractDaprClient {
* Called when the server response was not 2xx or when an exception was * Called when the server response was not 2xx or when an exception was
* thrown in the process * thrown in the process
* *
* @param call - in case of server error (4xx, 5xx) this contains the * @param call - in case of server error (4xx, 5xx) this contains the server
* server response in case of IO exception this is null * response in case of IO exception this is null
* @param e - contains the exception. in case of server error (4xx, * @param e - contains the exception. in case of server error (4xx, 5xx)
* 5xx) this is null * this is null
*/ */
public void onFailure(Call call, Exception e); public void onFailure(Call call, Exception e);