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 ++++++++
1 files changed, 8 insertions(+), 0 deletions(-)
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