fix npe bug

pmupkin · Oct 26, 2022 · 51e749d · 51e749d
1 parent 0ad1972
commit 51e749d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...h-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolAdaptor.java b/...h-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolAdaptor.java
@@ -95,8 +95,11 @@ public ProtocolTransportObject fromCloudEvent(CloudEvent cloudEvent) throws Prot
         }
         httpEventWrapper.setSysHeaderMap(sysHeaderMap);
         // ce data
-        Map<String, Object> dataContentMap = JsonUtils.deserialize(new String(cloudEvent.getData().toBytes(), Constants.DEFAULT_CHARSET),
+        String jsonStr = new String(cloudEvent.getData().toBytes(), Constants.DEFAULT_CHARSET);
+        if (StringUtils.isNotBlank(jsonStr)) {
+            Map<String, Object> dataContentMap = JsonUtils.deserialize(jsonStr,
             new TypeReference<Map<String, Object>>() {});
+        }
 
         String requestHeader = JsonUtils.serialize(dataContentMap.get(CONSTANTS_KEY_HEADERS));
         byte[] requestBody = JsonUtils.serialize(dataContentMap.get(CONSTANTS_KEY_BODY)).getBytes(StandardCharsets.UTF_8);