diff --git a/examples/rtmp_server/main.go b/examples/rtmp_server/main.go
index 8d089ef..4977b4a 100644
--- a/examples/rtmp_server/main.go
+++ b/examples/rtmp_server/main.go
@@ -163,12 +163,14 @@ func (s *server) handlePublish(conn *rtmp.Conn) {
 		return
 	}
 
+	metadata := conn.GetMetaData()
+
 	s.lock.Lock()
 
 	ch := s.channels[conn.URL.Path]
 	if ch == nil {
 		ch = &channel{}
-		ch.metadata = conn.GetMetaData()
+		ch.metadata = metadata
 		ch.que = pubsub.NewQueue()
 		ch.que.WriteHeader(streams)
 		for _, stream := range streams {