add log

zhangqian

2023-10-09 d6b81a185f55a0322c0d404c9048cfb0a47488b9

 nsq/nsq.go

@@ -74,12 +74,14 @@
         }
      }
   })
   logx.Infof("add consumer success, topic:%v", topic)
}

func (c *consumerManager) stop() {
   c.clients.Range(func(key, value any) bool {
      if consumer, ok := value.(*nsqclient.NsqConsumer); ok {
         nsqclient.DestroyNsqConsumer(consumer)
         logx.Infof("try stop consumer, topic : %v", key)
      }
      return true
   })