From ba5b2623226f0dd6da5e2e7964a1523a11f3a8fb Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期五, 15 一月 2021 15:46:26 +0800
Subject: [PATCH] 判断channel的长度，大于零往外弹消息
---
hbusc.go | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/hbusc.go b/hbusc.go
index 0de686e..50f0012 100644
--- a/hbusc.go
+++ b/hbusc.go
@@ -537,11 +537,11 @@
if h.sockHB == nil && h.sockRep == nil && h.sockPub == nil && h.sockSub == nil && h.sockWorker == nil {
return nil,nil, -1
}
- if len(h.chSub) >1 {
+ if len(h.chSub) >0 {
m := <-h.chSub
subMsg = m.info
}
- if len(h.chReply) > 1 {
+ if len(h.chReply) >0 {
m := <-h.chReply
replyMsg = m.info
replyKey = m.port
--
Gitblit v1.8.0