添加主从serf切换事件

zhangzengfei

2023-10-19 8d2a95fc0eeabe1b13d0a914c9ec2845d42c0be3

 pkg/nsqclient/consumer.go

@@ -90,9 +90,9 @@
   for {
      select {
      case <-n.ctx.Done():
         logx.Infof("[%s] %s", "stop consumer...", n.topic, n.channel)
         logx.Infof("[%s]%s stop consumer...", n.topic, n.channel)
         n.consumer.Stop()
         logx.Infof("[%s] %s", "stop consumer success", n.topic, n.channel)
         logx.Infof("[%s]%s stop consumer success", n.topic, n.channel)
         return nil
      }
   }