blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhangqian
2023-10-20 6bfbe5092d05cd75a8f8772ad715871f7639a42e 
 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


      }