diff --git a/trunk/src/app/srs_app_edge.cpp b/trunk/src/app/srs_app_edge.cpp
index cd4a2fdcb..f60bc7e6b 100644
--- a/trunk/src/app/srs_app_edge.cpp
+++ b/trunk/src/app/srs_app_edge.cpp
@@ -476,6 +476,8 @@ void SrsEdgeForwarder::stop()
     
     close_underlayer_socket();
     
+    queue->clear();
+    
     srs_freep(client);
     srs_freep(io);
     kbps->set_io(NULL, NULL);