hbusc.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
hbusc.go
@@ -209,6 +209,7 @@ if ri.PubTopic != nil && len(ri.PubTopic) > 0 { sockReply := bhomebus.OpenSocket() sockReply.ForceBind(int(regR.ReplyKey)) handle.printLog("after pubTopic forceBind") handle.wg.Add(1) //serve server reply go recvRoutine(ctx, sockReply, handle.wg, handle.chReply, handle.printLog) @@ -231,6 +232,7 @@ //订阅消息的socket sockSub := bhomebus.OpenSocket() //订阅所有主题 handle.printLog("start Sub topics") for _,v := range ri.SubTopic { subN := sockSub.Sub(v) handle.printLog("subTopic:", v, " ret n:", subN)