修改：广播消息未成功发送bug

git-svn-id: svn://47.119.165.148/zhub@113 e63fbceb-bcc3-4977-ac22-735b83d8d0f4
2021-03-04 07:00:14 +00:00
parent e1ad0399ff
commit bb3802f0aa
1 changed files with 1 additions and 1 deletions
--- 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 {