diff --git a/example/default/pullrtmp.yaml b/example/default/pullrtmp.yaml
new file mode 100644
index 0000000..a6afa6f
--- /dev/null
+++ b/example/default/pullrtmp.yaml
@@ -0,0 +1,5 @@
+global:
+  loglevel: debug
+rtmp:
+  pull:
+    live/test: rtmp://tv.lpsrtv.com/channellive/ch2
diff --git a/plugin/rtmp/pkg/net-connection.go b/plugin/rtmp/pkg/net-connection.go
index 40072dd..4f4cb3e 100644
--- a/plugin/rtmp/pkg/net-connection.go
+++ b/plugin/rtmp/pkg/net-connection.go
@@ -245,7 +245,7 @@ func (nc *NetConnection) readChunkType(h *ChunkHeader, chunkType byte) (err erro
 			nc.readSeqNum++
 			if chunkType == 0 {
 				// Message Stream ID 4bytes
-				if h.MessageStreamID, err = nc.ReadBE32(4); err != nil { // 读取Message Stream ID
+				if h.MessageStreamID, err = nc.ReadLE32(4); err != nil { // 读取Message Stream ID
 					return err
 				}
 			}
@@ -305,18 +305,18 @@ func (nc *NetConnection) RecvMessage() (msg *Chunk, err error) {
 					err = r.WriteAudio(msg.AVData.WrapAudio())
 				} else {
 					msg.AVData.Recycle()
-					if r.PubAudio {
-						nc.Warn("ReceiveAudio", "MessageStreamID", msg.MessageStreamID)
-					}
+					//if r.PubAudio {
+					//	nc.Warn("ReceiveAudio", "MessageStreamID", msg.MessageStreamID)
+					//}
 				}
 			case RTMP_MSG_VIDEO:
 				if r, ok := nc.Receivers[msg.MessageStreamID]; ok && r.PubVideo {
 					err = r.WriteVideo(msg.AVData.WrapVideo())
 				} else {
 					msg.AVData.Recycle()
-					if r.PubVideo {
-						nc.Warn("ReceiveVideo", "MessageStreamID", msg.MessageStreamID)
-					}
+					//if r.PubVideo {
+					//	nc.Warn("ReceiveVideo", "MessageStreamID", msg.MessageStreamID)
+					//}
 				}
 			}
 		}