等待收到退出完成信号再打印退出成功消息

zhangqian

2023-10-20 b84ef4231c64155482686485fe197a5d2426e086

等待收到退出完成信号再打印退出成功消息

 pkg/nsqclient/consumer.go

@@ -92,6 +92,7 @@
        case <-n.ctx.Done():
            logx.Infof("[%s]%s stop consumer...", n.topic, n.channel)
            n.consumer.Stop()
            <-n.consumer.StopChan
            logx.Infof("[%s]%s stop consumer success", n.topic, n.channel)
            return nil
        }