commit
b1192d5084
|
@ -1891,9 +1891,6 @@ int32_t tmq_consumer_close(tmq_t* tmq) {
|
|||
}
|
||||
|
||||
tmq_list_destroy(lst);
|
||||
|
||||
/*return rsp;*/
|
||||
return 0;
|
||||
}
|
||||
taosRemoveRef(tmqMgmt.rsetId, tmq->refId);
|
||||
return 0;
|
||||
|
|
Loading…
Reference in New Issue