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

liuxiaolong

2021-01-18 6a1b64b8b2933d5bc38a6084ff06cccda35110b7

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

 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)