diff --git a/examples/http_flv_and_rtmp_server/main.go b/examples/http_flv_and_rtmp_server/main.go
index dabb33a..eda03a3 100644
--- a/examples/http_flv_and_rtmp_server/main.go
+++ b/examples/http_flv_and_rtmp_server/main.go
@@ -53,8 +53,8 @@ func main() {
 		ch := channels[conn.URL.Path]
 		if ch == nil {
 			ch = &Channel{}
-			ch.que = pubsub.NewQueue(streams)
-			ch.que.SetMaxDuration(time.Minute)
+			ch.que = pubsub.NewQueue()
+			ch.que.WriteHeader(streams)
 			channels[conn.URL.Path] = ch
 		} else {
 			ch = nil