Fo示例:
func handler(msg jetstream.Msg) { err := doWork() if err != nil { _ = msg.NakWithDelay(time.Second * 10) } _ = msg.Ack() }
字符串我想获取当前尝试处理消息msg jetstream.Msg的次数,以便创建一个超时进程。我该如何做?
h43kikqp1#
我猜,它会是用于计数的局部变量?
var counter int err := doWork() if err != nil { // ... stufs counter++ }
字符串如果我的意思是“处理消息”,则func doWork()
doWork()
1条答案
按热度按时间h43kikqp1#
我猜,它会是用于计数的局部变量?
字符串
如果我的意思是“处理消息”,则func
doWork()