关闭消费者时先关闭连接，再停止消费者

zhangqian

2023-10-21 4c066543587bb0ec88a6723f4d66da60c36aec53

 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
      }
   }