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..9aab31f6c8 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 @@ -31,6 +31,7 @@ import java.io.IOException; import java.io.OutputStream; +import java.util.Objects; import com.sun.net.httpserver.HttpExchange; @@ -60,7 +61,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..dea40f8108 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); }