liuxiaolong
2021-01-26 9c20062535eb473909872fe815a0be672fdb8ceb
add logs
1个文件已修改
2 ■■■■■ 已修改文件
hbusc.go 2 ●●●●● 补丁 | 查看 | 原始文档 | 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)