diff --git a/source/libs/transport/src/transSrv.c b/source/libs/transport/src/transSrv.c index 3950a42ef0e7dc492325eb59e0d8e402943da717..787c538f2a3f8d3689ed4de7c1165f60cba7009e 100644 --- a/source/libs/transport/src/transSrv.c +++ b/source/libs/transport/src/transSrv.c @@ -292,7 +292,7 @@ void uvOnSendCb(uv_write_t* req, int status) { } transQueuePop(&conn->srvMsgs); tfree(msg); - msg = (SSrvMsg*)transQueueGet(&conn->srvMsgs, 0); + msg = (SSrvMsg*)transQueuePop(&conn->srvMsgs); if (msg != NULL) { uvStartSendRespInternal(msg); }