rocketmq源码之store模块
2017-11-03 本文已影响0人
Gahdamn
store启动
this.reputMessageService.start(); 这个服务会定时分拣到达的消息到其他消费队列里去
doreput主要就是干dispatch分拣
store会遍历所有实现dispatch接口的分拣器,调用他们的分拣接口
而有个分拣器完成cosumequeue的建立
this.reputMessageService.start(); 这个服务会定时分拣到达的消息到其他消费队列里去
doreput主要就是干dispatch分拣
store会遍历所有实现dispatch接口的分拣器,调用他们的分拣接口
而有个分拣器完成cosumequeue的建立