rocketmq源码之store模块

2017-11-03  本文已影响0人  Gahdamn

store启动

this.reputMessageService.start();   这个服务会定时分拣到达的消息到其他消费队列里去


doreput主要就是干dispatch分拣


store会遍历所有实现dispatch接口的分拣器,调用他们的分拣接口


而有个分拣器完成cosumequeue的建立


上一篇下一篇

猜你喜欢

热点阅读