update example code to the new version

This commit is contained in:
Eric Tang
2017-01-09 19:57:07 -05:00
parent cdca0d649c
commit bf48f24655

View File

@@ -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