Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

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

Jump to bottom

拉取消息超时，endChan和errChan相互阻塞 #20

Open
ming1028 opened this issue Nov 7, 2023 · 0 comments
Open

拉取消息超时，endChan和errChan相互阻塞 #20

ming1028 opened this issue Nov 7, 2023 · 0 comments

Comments

@ming1028
Copy link

ming1028 commented Nov 7, 2023

当时mqConsumer拉取消息超时的时候（默认35秒超时），程序会一直阻塞在ConsumerMessageOrderly()中，当到达外部设置的30秒超时的时候，就会阻塞在endChan,这是ConsumerMessageOrderly35秒超时触发错误，向errChan放入错误信息又因为外部30秒超时在阻塞，导致errchan被阻塞。解决办法异步执行 go ConsumerMessageOrderly()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@ming1028