diff --git a/client.go b/client.go
index 46d13f2..7e0812e 100644
--- a/client.go
+++ b/client.go
@@ -121,6 +121,8 @@ func (pusher *RTMPPusher) Push() error {
 			case Response_Result, Response_OnStatus:
 				if response, ok := msg.MsgData.(*ResponseCreateStreamMessage); ok {
 					pusher.StreamID = response.StreamId
+					pusher.audio.MessageStreamID = pusher.StreamID
+					pusher.video.MessageStreamID = pusher.StreamID
 					URL, _ := url.Parse(pusher.RemoteURL)
 					_, streamPath, _ := strings.Cut(URL.Path, "/")
 					_, streamPath, _ = strings.Cut(streamPath, "/")