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

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
      }