From e1ad0399ff8bb5c203d7b500e8b6bd5395085111 Mon Sep 17 00:00:00 2001
From: lxy <237809796@qq.com>
Date: Fri, 26 Feb 2021 07:18:53 +0000
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=EF=BC=9A=E6=9C=8D=E5=8A=A1?=
 =?UTF-8?q?=E5=86=85=E9=83=A8=E9=80=9A=E9=81=93=E6=89=A7=E8=A1=8C=E5=BC=82?=
 =?UTF-8?q?=E5=B8=B8=E6=8D=95=E8=8E=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

git-svn-id: svn://47.119.165.148/zhub@111 e63fbceb-bcc3-4977-ac22-735b83d8d0f4
---
 zsub/msg-consumer.go | 5 +++++
 1 file changed, 5 insertions(+)

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