1 files changed, 1 insertions, 4 deletions
diff --git a/code/core/msgq.c b/code/core/msgq.c
index 45df608..b928a2d 100644
--- a/code/core/msgq.c
+++ b/code/core/msgq.c
@@ -59,10 +59,7 @@ void ecp_conn_msgq_destroy(ECPConnMsgQ *msgq) {
     pthread_mutex_destroy(&msgq->mutex);
 }
 
-int ecp_conn_msgq_start(ECPConnection *conn, ecp_seq_t seq) {
-    ECPRBRecv *buf = conn->rbuf.recv;
-    ECPConnMsgQ *msgq = buf ? &buf->msgq : NULL;
-
+int ecp_conn_msgq_start(ECPConnMsgQ *msgq, ecp_seq_t seq) {
     if (msgq == NULL) return ECP_ERR;
 
     msgq->seq_max = seq;