hbusc.go
@@ -214,7 +214,6 @@ h.printLog("h.wg.Wait done") } //HeartBeat send func (h *BHBus) HeartBeat() error { procI := bhome_msg.ProcInfo{ @@ -228,8 +227,6 @@ return errors.New("send heartBeat return false") } } //更新主题列表 func (h *BHBus) UpdateNodeTopics(arr []NodeInfo) { @@ -304,6 +301,7 @@ rep := bhome_msg.MsgRequestTopicReply{ Data: data, } if bhsgo.SendReply(src, &rep) { return nil } @@ -321,7 +319,6 @@ return nil, errors.New("QueryProcs ret flase") } } //向主题通道中发布消息 func (h *BHBus) Pub(nodes []bhome_msg.BHAddress, msg *bhome_msg.MsgPublish) error {
