remove commit
This commit is contained in:
parent
3277607503
commit
19bbd68060
|
@ -354,6 +354,7 @@ void loop_consume(tmq_t* tmq) {
|
||||||
if (0 != g_stConfInfo.showMsgFlag) {
|
if (0 != g_stConfInfo.showMsgFlag) {
|
||||||
/*msg_process(tmqMsg);*/
|
/*msg_process(tmqMsg);*/
|
||||||
}
|
}
|
||||||
|
/*tmq_commit(tmq, NULL, false);*/
|
||||||
tmq_message_destroy(tmqMsg);
|
tmq_message_destroy(tmqMsg);
|
||||||
} else {
|
} else {
|
||||||
break;
|
break;
|
||||||
|
|
Loading…
Reference in New Issue