From 9c20062535eb473909872fe815a0be672fdb8ceb Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期二, 26 一月 2021 14:10:11 +0800
Subject: [PATCH] add logs
---
hbusc.go | 2 ++
1 files changed, 2 insertions(+), 0 deletions(-)
diff --git a/hbusc.go b/hbusc.go
index 6da3374..3c5b250 100644
--- a/hbusc.go
+++ b/hbusc.go
@@ -209,6 +209,7 @@
if ri.PubTopic != nil && len(ri.PubTopic) > 0 {
sockReply := bhomebus.OpenSocket()
sockReply.ForceBind(int(regR.ReplyKey))
+ handle.printLog("after pubTopic forceBind")
handle.wg.Add(1)
//serve server reply
go recvRoutine(ctx, sockReply, handle.wg, handle.chReply, handle.printLog)
@@ -231,6 +232,7 @@
//璁㈤槄娑堟伅鐨剆ocket
sockSub := bhomebus.OpenSocket()
//璁㈤槄鎵�鏈変富棰�
+ handle.printLog("start Sub topics")
for _,v := range ri.SubTopic {
subN := sockSub.Sub(v)
handle.printLog("subTopic:", v, " ret n:", subN)
--
Gitblit v1.8.0