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) {