rocketmq-baiji / rocketmq

Mirror of Apache RocketMQ
Apache License 2.0
4 stars 20 forks source link

[ISSUE #2]Implement the globally ordered consumer(第四组) #12

Open CHYbeta opened 6 years ago

CHYbeta commented 6 years ago

题目 全局排序的Consumer

fix issue #2

Brief changelog

实现了对于单个Consumer的全局有序消息读取机制,遍历所有message queue中第一个message,比较并找到时间最早的message进行处理。