* FIX [hook] Fix that some msgs from external are forwarded to webhoo…

…k handler. Signed-off-by: wanghaemq <wangwei@emqx.io>
nanomq · Jan 3, 2024 · 5e91bfd · 5e91bfd
1 parent 2e716f0
commit 5e91bfd
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/nanomq/webhook_inproc.c b/nanomq/webhook_inproc.c
@@ -314,9 +314,13 @@ hook_work_cb(void *arg)
 		body = (char *) nng_msg_body(msg);
 
 		root = NULL;
-		if (exconf->count > 0) {
-			// Only parse msg when exchange is enabled
-			root = cJSON_Parse(body);
+		// TODO Not efficent
+		// Only parse msg when exchange is enabled
+		root = cJSON_Parse(body);
+		cJSON *idjo = cJSON_GetObjectItem(root, "ID");
+		if (!idjo) {
+			cJSON_Delete(root);
+			root = NULL;
 		}
 		if (root) {
 			cJSON *idjo = cJSON_GetObjectItem(root, "ID");