Go语言 是否可以得到当前尝试处理消息msg jetstream.msg的次数?

r1zhe5dt  于 9个月前  发布在  Go
关注(0)|答案(1)|浏览(105)

Fo示例:

func handler(msg jetstream.Msg) {
    err := doWork()
    if err != nil {
        _ = msg.NakWithDelay(time.Second * 10)
    }

    _ = msg.Ack()
}

字符串
我想获取当前尝试处理消息msg jetstream.Msg的次数,以便创建一个超时进程。我该如何做?

h43kikqp

h43kikqp1#

我猜,它会是用于计数的局部变量?

var counter int
err := doWork()
if err != nil {
// ... stufs
counter++
}

字符串
如果我的意思是“处理消息”,则func doWork()

相关问题