From 5c404dfd6344826f909451a7bef602c78d091f90 Mon Sep 17 00:00:00 2001 From: Piotr Jaszczyk Date: Mon, 8 Apr 2019 10:10:01 +0200 Subject: Handle non-sucessfull CBS http responses Change-Id: I8bdd730af80e343503aee64305ca432d933774a6 Issue-ID: DCAEGEN2-1401 Signed-off-by: Piotr Jaszczyk --- .../services/sdk/rest/services/cbs/client/impl/CbsClientImpl.java | 2 ++ 1 file changed, 2 insertions(+) (limited to 'rest-services/cbs-client/src/main') diff --git a/rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/CbsClientImpl.java b/rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/CbsClientImpl.java index 98f3cc97..6f37cd2b 100644 --- a/rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/CbsClientImpl.java +++ b/rest-services/cbs-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/cbs/client/impl/CbsClientImpl.java @@ -25,6 +25,7 @@ import java.net.MalformedURLException; import java.net.URL; import org.jetbrains.annotations.NotNull; import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.HttpMethod; +import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.HttpResponse; import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.ImmutableHttpRequest; import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.RxHttpClient; import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.CbsClient; @@ -56,6 +57,7 @@ public class CbsClientImpl implements CbsClient { .diagnosticContext(request.diagnosticContext()) .build()) .flatMap(httpClient::call) + .doOnNext(HttpResponse::throwIfUnsuccessful) .map(resp -> resp.bodyAsJson(JsonObject.class)) .doOnNext(this::logCbsResponse); } -- cgit 1.2.3-korg