diff --git a/rtmp/server.go b/rtmp/server.go
index 94e9994..89df686 100644
--- a/rtmp/server.go
+++ b/rtmp/server.go
@@ -49,5 +49,8 @@ func handle_conn(conn net.Conn, stream_live *bool) {
 	if !CreateStream(chunk_wrapper) {
 		return
 	}
+	if !PublishAsKey(chunk_wrapper) {
+		return
+	}
 	*stream_live = false
 }