parent: 9a2c8728 | 补丁 | 提交 | show whitespace
zhangqian
2023-10-18 ce72e23e983422eadbd27311ab1467dbc2b854ae 
add log
1个文件已修改
5 ■■■■■ 已修改文件
pkg/nsqclient/consumer.go 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 
 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


        }


    }