diff --git a/util/src/main/java/io/kubernetes/client/util/generic/KubernetesApiResponse.java b/util/src/main/java/io/kubernetes/client/util/generic/KubernetesApiResponse.java index 54e86cb93d..77b65364f0 100644 --- a/util/src/main/java/io/kubernetes/client/util/generic/KubernetesApiResponse.java +++ b/util/src/main/java/io/kubernetes/client/util/generic/KubernetesApiResponse.java @@ -59,8 +59,8 @@ public boolean isSuccess() { */ public KubernetesApiResponse throwsApiException() throws ApiException { return onFailure( - errorStatus -> { - throw new ApiException(errorStatus.toString()); + (code, errorStatus) -> { + throw new ApiException(code, errorStatus.toString()); }); } @@ -74,12 +74,12 @@ public KubernetesApiResponse throwsApiException() throws ApiException public KubernetesApiResponse onFailure(ErrorStatusHandler errorStatusHandler) throws ApiException { if (!isSuccess()) { - errorStatusHandler.handle(this.status); + errorStatusHandler.handle(this.getHttpStatusCode(), this.status); } return this; } public interface ErrorStatusHandler { - void handle(V1Status errorStatus) throws ApiException; + void handle(int code, V1Status errorStatus) throws ApiException; } } diff --git a/util/src/test/java/io/kubernetes/client/util/generic/KubernetesApiResponseTest.java b/util/src/test/java/io/kubernetes/client/util/generic/KubernetesApiResponseTest.java index db04f933e0..1a26c0235d 100644 --- a/util/src/test/java/io/kubernetes/client/util/generic/KubernetesApiResponseTest.java +++ b/util/src/test/java/io/kubernetes/client/util/generic/KubernetesApiResponseTest.java @@ -55,7 +55,7 @@ public void testErrorStatusHandler() throws ApiException { podClient .delete("default", "foo") .onFailure( - errStatus -> { + (code, errStatus) -> { catched.set(true); }) .getObject());