fix

liuxiaolong

2021-09-27 11dae002175b4a4fa596b6519882c8c5cb9587ed

fix

 hbusc.go

@@ -126,8 +126,6 @@

    handle.printLog("register done!" )

    handle.wg = &sync.WaitGroup{}

    //有订阅消息才需要启动协程接收消息
    if len(ri.SubTopic) > 0 {
        handle.printLog("sub topics")
@@ -154,11 +152,11 @@
        }
    }

    //if len(ri.SubTopic) > 0 || len(ri.SubNetTopic) > 0 {
    if len(ri.SubTopic) > 0 || len(ri.SubNetTopic) > 0 {
        //启动订阅信息接收
        handle.wg.Add(1)
        go recvSubRoutine(ctx, handle.wg, handle.ChSub, handle.printLog)
    //}
    }

    return handle, nil
}