From 11dae002175b4a4fa596b6519882c8c5cb9587ed Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期一, 27 九月 2021 15:02:34 +0800
Subject: [PATCH] fix
---
hbusc.go | 6 ++----
1 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/hbusc.go b/hbusc.go
index 4a520a0..a13871f 100644
--- a/hbusc.go
+++ b/hbusc.go
@@ -126,8 +126,6 @@
handle.printLog("register done!" )
- handle.wg = &sync.WaitGroup{}
-
//鏈夎闃呮秷鎭墠闇�瑕佸惎鍔ㄥ崗绋嬫帴鏀舵秷鎭�
if len(ri.SubTopic) > 0 {
handle.printLog("sub topics")
@@ -154,11 +152,11 @@
}
}
- //if len(ri.SubTopic) > 0 || len(ri.SubNetTopic) > 0 {
+ if len(ri.SubTopic) > 0 || len(ri.SubNetTopic) > 0 {
//鍚姩璁㈤槄淇℃伅鎺ユ敹
handle.wg.Add(1)
go recvSubRoutine(ctx, handle.wg, handle.ChSub, handle.printLog)
- //}
+ }
return handle, nil
}
--
Gitblit v1.8.0