fix

liuxiaolong

2021-09-27 11dae002175b4a4fa596b6519882c8c5cb9587ed

 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
}