This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 0ac09dee7 [ISSUE #5647]Polish PullMessageService some methods
parameter name (#5650)
add 49fc6eded [ISSUE #5568] Support long length group and topic for pop
mode consumption (#5611)
No new revisions were added by this update.
Summary of changes:
.../broker/processor/PopMessageProcessor.java | 33 +++-
.../broker/processor/PopReviveService.java | 9 +-
.../org/apache/rocketmq/broker/util/HookUtils.java | 28 ++-
.../apache/rocketmq/broker/util/HookUtilsTest.java | 69 +++++++
.../rocketmq/client/impl/MQClientAPIImpl.java | 42 ++---
.../rocketmq/common/message/MessageDecoder.java | 30 +--
.../rocketmq/common/message/MessageExtBatch.java | 4 +-
.../common/message/MessageExtBrokerInner.java | 10 +
.../rocketmq/common/message/MessageVersion.java | 22 +++
.../common/message/MessageDecoderTest.java | 48 +++--
.../proxy/service/message/LocalMessageService.java | 30 +--
.../java/org/apache/rocketmq/store/CommitLog.java | 26 ++-
.../apache/rocketmq/store/MessageExtEncoder.java | 43 +++--
.../rocketmq/store/config/MessageStoreConfig.java | 15 ++
.../rocketmq/store/dledger/DLedgerCommitLog.java | 31 +++-
.../rocketmq/test/retry/PopConsumerRetryIT.java | 203 +++++++++++++++++++++
16 files changed, 547 insertions(+), 96 deletions(-)
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/util/HookUtilsTest.java
create mode 100644
test/src/test/java/org/apache/rocketmq/test/retry/PopConsumerRetryIT.java
