From 4faf0eb9d385137e56b17a2ae375800aeb82ef41 Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Thu, 9 Jan 2025 15:53:47 +0800 Subject: [PATCH] fix:[TD-33498]clear msg if unsubscribe --- source/client/src/clientTmq.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c index f49adb83f3..78bceb4ef8 100644 --- a/source/client/src/clientTmq.c +++ b/source/client/src/clientTmq.c @@ -2606,6 +2606,7 @@ int32_t tmq_unsubscribe(tmq_t* tmq) { } code = tmq_subscribe(tmq, lst); tmq_list_destroy(lst); + tmqClearUnhandleMsg(tmq); if(code != 0){ goto END; }