diff --git a/client.go b/client.go
index 1f6e103..886123f 100644
--- a/client.go
+++ b/client.go
@@ -102,7 +102,8 @@ func (pusher *RTMPPusher) Push() error {
 				if response, ok := msg.MsgData.(*ResponseCreateStreamMessage); ok {
 					pusher.StreamID = response.StreamId
 					URL, _ := url.Parse(pusher.RemoteURL)
-					ps := strings.Split(URL.Path, "/")
+					_, streamPath, _ := strings.Cut(URL.Path, "/")
+					_, streamPath, _ = strings.Cut(streamPath, "/")
 					pusher.Args = URL.Query()
 					pusher.SendMessage(RTMP_MSG_AMF0_COMMAND, &PublishMessage{
 						CURDStreamMessage{
@@ -112,7 +113,7 @@ func (pusher *RTMPPusher) Push() error {
 							},
 							response.StreamId,
 						},
-						ps[len(ps)-1],
+						streamPath,
 						"live",
 					})
 				} else if response, ok := msg.MsgData.(*ResponsePublishMessage); ok {
diff --git a/server.go b/server.go
index dc85301..9a88bfe 100644
--- a/server.go
+++ b/server.go
@@ -166,10 +166,14 @@ func (config *RTMPConfig) ServeTCP(conn *net.TCPConn) {
 			case RTMP_MSG_AUDIO:
 				if r, ok := receivers[msg.MessageStreamID]; ok {
 					r.ReceiveAudio(msg)
+				} else {
+					RTMPPlugin.Warn("ReceiveAudio", zap.Uint32("MessageStreamID", msg.MessageStreamID))
 				}
 			case RTMP_MSG_VIDEO:
 				if r, ok := receivers[msg.MessageStreamID]; ok {
 					r.ReceiveVideo(msg)
+				} else {
+					RTMPPlugin.Warn("ReceiveVideo", zap.Uint32("MessageStreamID", msg.MessageStreamID))
 				}
 			}
 		} else {