diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c
index 17990761a4..4f1c890295 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;
   }