liuxiaolong
2020-12-30 b93b67a7e237cbf59569dcaacfa84257856ba16e
hbusc.go
@@ -487,6 +487,17 @@
   }
}
//注销订阅的主题
func (h *BHBus) DeSub(topics []string) {
   if topics != nil {
      for _,t := range topics {
         if n := h.sockSub.sock.Desub(t); n != 0 {
            h.printLog("DeSub topic:", t, " n:", n)
         }
      }
   }
}
//获取sub 或者需要reply的消息
func (h *BHBus) GetMsg() (subMsg *MsgInfo, replyMsg *MsgInfo, replyKey int) {