diff --git a/trunk/src/app/srs_app_recv_thread.cpp b/trunk/src/app/srs_app_recv_thread.cpp
index f12b028ef..cc64a4853 100644
--- a/trunk/src/app/srs_app_recv_thread.cpp
+++ b/trunk/src/app/srs_app_recv_thread.cpp
@@ -140,7 +140,6 @@ SrsQueueRecvThread::SrsQueueRecvThread(SrsConsumer* consumer, SrsRtmpServer* rtm
     _consumer = consumer;
     rtmp = rtmp_sdk;
     recv_error_code = ERROR_SUCCESS;
-    _consumer = NULL;
 }
 
 SrsQueueRecvThread::~SrsQueueRecvThread()