diff --git a/protocol/rtmp/rtmprelay/rtmprelay.go b/protocol/rtmp/rtmprelay/rtmprelay.go
index af152e2..460fb0a 100644
--- a/protocol/rtmp/rtmprelay/rtmprelay.go
+++ b/protocol/rtmp/rtmprelay/rtmprelay.go
@@ -77,7 +77,7 @@ func (self *RtmpRelay) sendPublishChunkStream() {
 			if ctrlcmd == STOP_CTRL {
 				self.connectPublishClient.Close(nil)
 				log.Debugf("sendPublishChunkStream close: playurl=%s, publishurl=%s", self.PlayUrl, self.PublishUrl)
-				break
+				return
 			}
 		}
 	}
diff --git a/protocol/rtmp/rtmprelay/staticrelay.go b/protocol/rtmp/rtmprelay/staticrelay.go
index 8723850..2783c8f 100644
--- a/protocol/rtmp/rtmprelay/staticrelay.go
+++ b/protocol/rtmp/rtmprelay/staticrelay.go
@@ -170,7 +170,7 @@ func (self *StaticPush) HandleAvPacket() {
 			if ctrlcmd == STATIC_RELAY_STOP_CTRL {
 				self.connectClient.Close(nil)
 				log.Debugf("Static HandleAvPacket close: publishurl=%s", self.RtmpUrl)
-				break
+				return
 			}
 		}
 	}