nsq icon indicating copy to clipboard operation
nsq copied to clipboard

consumer.Stop() 阻塞问题

Open freedba opened this issue 4 years ago • 2 comments

各位大佬: 我在调用consumer.Stop() 时遇到了阻塞,有没有办法加个超时?谢谢!

freedba avatar Oct 22 '21 02:10 freedba

阻塞是不是因为注册的消费回调函数处理时阻塞了, 没有退出逻辑, 可以加一个, 这样stop的时候就不会阻塞了

absolute8511 avatar Oct 25 '21 01:10 absolute8511

谢谢提醒,应该是这个接口函数HandleMessage阻塞了。:)

freedba avatar Oct 27 '21 01:10 freedba