Merge pull request #29540 from taosdata/fix/TD-33498-main
fix:[TD-33498]clear msg if unsubscribe
This commit is contained in:
commit
b4f03124d0
|
@ -2606,6 +2606,7 @@ int32_t tmq_unsubscribe(tmq_t* tmq) {
|
||||||
}
|
}
|
||||||
code = tmq_subscribe(tmq, lst);
|
code = tmq_subscribe(tmq, lst);
|
||||||
tmq_list_destroy(lst);
|
tmq_list_destroy(lst);
|
||||||
|
tmqClearUnhandleMsg(tmq);
|
||||||
if(code != 0){
|
if(code != 0){
|
||||||
goto END;
|
goto END;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue