RocketMQ Push消费流程源码分析
2020-11-14 23:23:43 20 举报RocketMQ Push消费流程
作者其他创作
大纲/内容
MessageListener
rebalanceImmediately()
PullAPIWrapper
rebalanceByTopic
pullMessage
executePullRequestImmediately
wakeup
doRebalance
PullMessageService
RebalanceImpl
ConsumeMessageService
processConsumeResult
dispatchPullRequest
updateProcessQueueTableInRebalance
consumeMessage
pullKernelImpl
loop
putMessage
updateOffset
OffsetStore
MQClientInstance
submitConsumeRequest
DefaultMQPushConsumerImpl
RebalanceService
ProcessQueue
pullMessageAsync
PullCallback
0 条评论
下一页
