nsq
nsq copied to clipboard
consumer.Stop() 阻塞问题
各位大佬: 我在调用consumer.Stop() 时遇到了阻塞,有没有办法加个超时?谢谢!
阻塞是不是因为注册的消费回调函数处理时阻塞了, 没有退出逻辑, 可以加一个, 这样stop的时候就不会阻塞了
谢谢提醒,应该是这个接口函数HandleMessage阻塞了。:)