阅读背景:

RocketMQ——Consumer篇:PUSH模式下的消息拉取(DefaultMQPushConsumer)

来源:互联网 

DefaultMQPushConsumerImpl中各个对象的主要功能如下:

RebalancePushImpl:主要负责决定,当前的consumer应该从哪些Queue中消费消息;RebalancePus




你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: