This is an automated email from the ASF dual-hosted git repository.
kaili pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from c96a0b5665 [ISSUE #6933] Support delete expired or damaged file in
tiered storage and optimize fetch code (#6952)
add 8ab99aceb7 [ISSUE #6754] Support reentrant orderly consumption for
proxy (#6755)
No new revisions were added by this update.
Summary of changes:
WORKSPACE | 2 +-
pom.xml | 2 +-
.../proxy/common/MessageReceiptHandle.java | 8 ++-
.../rocketmq/proxy/common/ReceiptHandleGroup.java | 71 ++++++++++++++++++----
.../grpc/v2/consumer/ReceiveMessageActivity.java | 3 +-
.../proxy/processor/ConsumerProcessor.java | 6 +-
.../proxy/processor/DefaultMessagingProcessor.java | 3 +-
.../proxy/processor/MessagingProcessor.java | 1 +
.../proxy/processor/ReceiptHandleProcessor.java | 10 ++-
.../proxy/common/ReceiptHandleGroupTest.java | 41 +++++++++++--
.../v2/consumer/ReceiveMessageActivityTest.java | 3 +-
.../proxy/processor/ConsumerProcessorTest.java | 1 +
.../processor/ReceiptHandleProcessorTest.java | 54 ++++++++++++----
13 files changed, 163 insertions(+), 42 deletions(-)
