[fix][admin] Fix get-publish-rete Admin API handle exception behavior (…

…apache#16001)
bestming8 · Jun 11, 2022 · addfbd3 · addfbd3
1 parent c4ee109
commit addfbd3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java
@@ -773,9 +773,10 @@ public void getPublishRate(@Suspended AsyncResponse asyncResponse,
             @PathParam("namespace") String namespace) {
         validateNamespaceName(property, namespace);
         internalGetPublishRateAsync()
-                .thenAccept(publishRate -> asyncResponse.resume(publishRate))
+                .thenAccept(asyncResponse::resume)
                 .exceptionally(ex -> {
                     log.error("Failed to get publish rate for namespace {}", namespaceName, ex);
+                    resumeAsyncResponseExceptionally(asyncResponse, ex);
                     return null;
                 });
     }