From 7cf6b23c83e1c4efb8567a16ab2f401be4b6d1bf Mon Sep 17 00:00:00 2001 From: liuxiaolong <liuxiaolong@aiotlink.com> Date: 星期五, 05 二月 2021 18:19:21 +0800 Subject: [PATCH] add PublishNetTimeout --- hbusc.go | 8 ++++++++ 1 files changed, 8 insertions(+), 0 deletions(-) diff --git a/hbusc.go b/hbusc.go index 8161f8c..d0f9222 100644 --- a/hbusc.go +++ b/hbusc.go @@ -538,6 +538,14 @@ return err } +func (h *BHBus) PubTimeout(nodes []bhomebus.NetNode, msg *MsgInfo, timeout int) int { + data,err := json.Marshal(*msg) + if err == nil { + return h.sockPub.sock.PubTimeout(nodes, msg.Topic, data, timeout) + } + return -1 +} + //杩藉姞璁㈤槄鐨勪富棰樻秷鎭� func (h *BHBus) Sub(topics []string) { if topics != nil { -- Gitblit v1.8.0