pub消息返回值大于0表示发布成功

liuxiaolong

2021-01-18 6a1b64b8b2933d5bc38a6084ff06cccda35110b7

 hbusc.go

@@ -502,7 +502,7 @@
func (h *BHBus) Pub(nodes []bhomebus.NetNode, msg *MsgInfo) error {
   data,err := json.Marshal(*msg)
   if err == nil {
      if n := h.sockPub.sock.PubTimeout(nodes, msg.Topic, data, h.conf.pubTimeOut);n == 0 {
      if n := h.sockPub.sock.PubTimeout(nodes, msg.Topic, data, h.conf.pubTimeOut);n > 0 {
         return nil
      } else {
         return fmt.Errorf("pub err n:%d", n)