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