diff --git a/zsub/msg-consumer.go b/zsub/msg-consumer.go
index 5f9fa16..6b03d43 100644
--- a/zsub/msg-consumer.go
+++ b/zsub/msg-consumer.go
@@ -65,6 +65,11 @@ func msgAccept(v Message) {
 
 	// 内部执行指令 加入执行队列
 	funChan <- func() {
+		defer func() {
+			if r := recover(); r != nil {
+				log.Println("funChan Recovered:", r)
+			}
+		}()
 		switch cmd {
 		case "subscribe":
 			// subscribe x y z