We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
我在回调函数里设置通道缓冲大小是1,通道缓冲消费完这一条后,立即调用Consumer.Stop(),这时我查看队列的数据少了有20条,请问多消费的消息是不是丢了?谢谢!
The text was updated successfully, but these errors were encountered:
stop后就不会ack消息了, 理论上不会丢, 或者关闭自动ack参数, 这样消费完自己ack
Sorry, something went wrong.
No branches or pull requests
我在回调函数里设置通道缓冲大小是1,通道缓冲消费完这一条后,立即调用Consumer.Stop(),这时我查看队列的数据少了有20条,请问多消费的消息是不是丢了?谢谢!
The text was updated successfully, but these errors were encountered: