youzan/nsq

consumer.Stop() 阻塞问题

freedba opened this issue · 2 comments

freedba commented

各位大佬：
我在调用consumer.Stop() 时遇到了阻塞，有没有办法加个超时？谢谢！

absolute8511 commented

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

freedba commented

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