This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 0faa0a2c7 [ISSUE #6414] polish
MQClientAPIImpl.getDefaultTopicRouteInfoFromName… (#6452)
add 1818c2d50 [ISSUE #4890] BugFix: fix binary search consume offset by
time (#6429)
No new revisions were added by this update.
Summary of changes:
.../org/apache/rocketmq}/common/BoundaryType.java | 2 +-
.../rocketmq/remoting/netty/FileRegionEncoder.java | 2 +-
.../org/apache/rocketmq/store/ConsumeQueue.java | 167 ++++++++++++++++++---
.../org/apache/rocketmq/store/MappedFileQueue.java | 85 +++++++++++
.../rocketmq/store/logfile/DefaultMappedFile.java | 29 ++++
.../rocketmq/store/DefaultMessageStoreTest.java | 16 +-
.../store/queue/BatchConsumeMessageTest.java | 2 +-
7 files changed, 267 insertions(+), 36 deletions(-)
copy {tieredstore/src/main/java/org/apache/rocketmq/tieredstore =>
common/src/main/java/org/apache/rocketmq}/common/BoundaryType.java (96%)
