add log

zhangqian

2023-10-18 ce72e23e983422eadbd27311ab1467dbc2b854ae

 pkg/nsqclient/consumer.go

@@ -1,6 +1,7 @@
package nsqclient

import (
   "apsClient/pkg/logx"
   "context"
   "fmt"
   "time"
@@ -89,9 +90,9 @@
   for {
      select {
      case <-n.ctx.Done():
         fmt.Println("[%s] %s,%s", "stop consumer", n.topic, n.channel)
         logx.Infof("[%s] %s", "stop consumer...", n.topic, n.channel)
         n.consumer.Stop()
         fmt.Println("[%s] %s,%s", "stop consumer success", n.topic, n.channel)
         logx.Infof("[%s] %s", "stop consumer success", n.topic, n.channel)
         return nil
      }
   }