From 545fb87bae9b38f04495c6ac311f6ba651720b44 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期一, 27 九月 2021 15:58:03 +0800
Subject: [PATCH] ReadSub set timeout 100

---
 hbusc.go |    4 ++--
 1 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/hbusc.go b/hbusc.go
index a13871f..3fc0924 100644
--- a/hbusc.go
+++ b/hbusc.go
@@ -167,11 +167,11 @@
 	for {
 		select {
 		case <-ctx.Done():
-			logFn("recvRoutine ctx.Done")
+			logFn("recvSubRoutine ctx.Done")
 			wg.Done()
 			return
 		default:
-			if bhsgo.ReadSub(&procId, &msg, -1) {
+			if bhsgo.ReadSub(&procId, &msg, 100) {
 				ch <- msg
 				logFn("ReadSub topic:", string(msg.Topic), " data:", string(msg.Data))
 

--
Gitblit v1.8.0