You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2023/03/24 02:15:49 UTC
[rocketmq] branch develop updated (0faa0a2c7 -> 1818c2d50)
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%)