diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/QueryWebHookConfigByIdHandler.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/QueryWebHookConfigByIdHandler.java index 55e726e455..35ea9a6714 100644 --- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/QueryWebHookConfigByIdHandler.java +++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/QueryWebHookConfigByIdHandler.java @@ -30,7 +30,7 @@ import java.io.IOException; import java.io.OutputStream; - +import java.util.Objects; import com.sun.net.httpserver.HttpExchange; @@ -60,7 +60,7 @@ public void handle(HttpExchange httpExchange) throws IOException { try (OutputStream out = httpExchange.getResponseBody()) { WebHookConfig result = operation.queryWebHookConfigById(webHookConfig); // operating result - out.write(JsonUtils.toJSONString(result).getBytes(Constants.DEFAULT_CHARSET)); + out.write(Objects.requireNonNull(JsonUtils.toJSONString(result)).getBytes(Constants.DEFAULT_CHARSET)); } catch (Exception e) { log.error("get WebHookConfigOperation implementation Failed.", e); } diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/QueryWebHookConfigByManufacturerHandler.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/QueryWebHookConfigByManufacturerHandler.java index f49e7942d3..3a16cce36c 100644 --- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/QueryWebHookConfigByManufacturerHandler.java +++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/QueryWebHookConfigByManufacturerHandler.java @@ -73,7 +73,7 @@ public void handle(HttpExchange httpExchange) throws IOException { try (OutputStream out = httpExchange.getResponseBody()) { List result = operation.queryWebHookConfigByManufacturer(webHookConfig, pageNum, pageSize); // operating result - out.write(JsonUtils.toJSONString(result).getBytes(Constants.DEFAULT_CHARSET)); + out.write(Objects.requireNonNull(JsonUtils.toJSONString(result)).getBytes(Constants.DEFAULT_CHARSET)); } catch (Exception e) { log.error("get WebHookConfigOperation implementation Failed.", e); }