From 8324f872ef3a4d0c978a9b1d062800c6a1701c12 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期五, 01 十二月 2023 09:58:17 +0800 Subject: [PATCH] fix --- pkg/nsqclient/consumer.go | 7 ++++--- 1 files changed, 4 insertions(+), 3 deletions(-) diff --git a/pkg/nsqclient/consumer.go b/pkg/nsqclient/consumer.go index fe09c27..78908dc 100644 --- a/pkg/nsqclient/consumer.go +++ b/pkg/nsqclient/consumer.go @@ -91,9 +91,6 @@ select { case <-n.ctx.Done(): logx.Infof("[%s] stop consumer...", n.topic) - n.consumer.Stop() - <-n.consumer.StopChan - logx.Infof("[%s] stop consumer success", n.topic) for _, addr := range qAddr { err = n.consumer.DisconnectFromNSQD(addr) if err != nil { @@ -102,6 +99,10 @@ logx.Infof("disconnect from nsq server success, addr: %v, topic: %v", addr, n.topic) } } + n.consumer.Stop() + <-n.consumer.StopChan + logx.Infof("[%s] stop consumer success", n.topic) + return nil } } -- Gitblit v1.8.0