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
---
micronode.go | 8 ++++++++
hbusc.go | 8 ++++++++
2 files changed, 16 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 {
diff --git a/micronode.go b/micronode.go
index 214fcf3..df721e8 100644
--- a/micronode.go
+++ b/micronode.go
@@ -241,6 +241,14 @@
return ms.handle.Pub(nodes, pi)
}
+func (ms *MicroNode) PublishNetTimeout(nodes []bhomebus.NetNode, topic string, msg []byte, timeout int) int {
+ pi := &MsgInfo{
+ Topic: topic,
+ Body: msg,
+ }
+ return ms.handle.PubTimeout(nodes, pi, timeout)
+}
+
//璁㈤槄涓婚
func (ms *MicroNode) Subscribe(topics []string) {
ms.handle.Sub(topics)
--
Gitblit v1.8.0