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.

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

rocketmq —— retry #54

Closed
carryxyh opened this issue Jun 5, 2019 · 0 comments
Closed

rocketmq —— retry #54

carryxyh opened this issue Jun 5, 2019 · 0 comments

Comments

@carryxyh
Copy link
Owner

carryxyh commented Jun 5, 2019

发送失败之后会把消息重新投递到broker上。这个地方会在consumer端带上一个delaylevel，默认0，由broker控制重试，-1表示直接进入死信队列，>0表示由客户端控制重试。

broker在存储消息的时候发现delaylevel > 0，消息自动进入schedule里。然后到时会把schedule的队列里的数据放到retry队列里。

consumer在启动的时候，会自动订阅retry队列（retry队列每个consumer group一个）。
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
@carryxyh