From bb3802f0aa9a2a1ced6f1628edee381876434ffb Mon Sep 17 00:00:00 2001
From: lxy <237809796@qq.com>
Date: Thu, 4 Mar 2021 07:00:14 +0000
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=9A=E5=B9=BF=E6=92=AD?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=9C=AA=E6=88=90=E5=8A=9F=E5=8F=91=E9=80=81?=
 =?UTF-8?q?bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

git-svn-id: svn://47.119.165.148/zhub@113 e63fbceb-bcc3-4977-ac22-735b83d8d0f4
---
 zsub/zgroup.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/zsub/zgroup.go b/zsub/zgroup.go
index d992161..210db29 100644
--- a/zsub/zgroup.go
+++ b/zsub/zgroup.go
@@ -26,7 +26,7 @@ func (g *ZGroup) appendTo(c *ZConn) {
 	// create new goroutine consumer message
 	unsubChan := make(chan int, 0)
 	c.substoped[topic] = unsubChan
-	c.appendTo(g.conns)
+	g.conns = c.appendTo(g.conns)
 	go func() {
 		for {
 			select {