fix:[TD-33498]clear msg if unsubscribe

2025-01-09 15:53:47 +08:00 · 2025-01-09 15:53:47 +08:00 · 4faf0eb9d3
parent cc6b4beb5d
commit 4faf0eb9d3
1 changed files with 1 additions and 0 deletions
--- 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;
  }