This is an automated email from the ASF dual-hosted git repository.
yukon pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 6fd1bb9a2 [ISSUE #6358] Add chinese docs about
persistent-unique-broker-id (#6359)
new 667ebbcc1 ReceiptHandleProcessor message renewal strategy optimization
#6232
new 06a87e650 ReceiptHandleProcessor message renewal strategy optimization
#6232
new fce64608b ReceiptHandleProcessor message renewal strategy optimization
#6232
new 1e3e7638f ReceiptHandleProcessor message renewal strategy optimization
#6232
new feb1f3077 ReceiptHandleProcessor message renewal strategy optimization
new 877f146f5 ReceiptHandleProcessor message renewal strategy optimization
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../proxy/common/MessageReceiptHandle.java | 10 ++++
.../rocketmq/proxy/common/RenewStrategyPolicy.java | 70 ++++++++++++++++++++++
.../apache/rocketmq/proxy/config/ProxyConfig.java | 23 ++++---
.../grpc/v2/consumer/ReceiveMessageActivity.java | 2 +-
.../proxy/processor/ReceiptHandleProcessor.java | 7 ++-
.../proxy/common/RenewStrategyPolicyTest.java | 66 ++++++++++++++++++++
.../processor/ReceiptHandleProcessorTest.java | 48 +++++++++++----
7 files changed, 201 insertions(+), 25 deletions(-)
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/common/RenewStrategyPolicy.java
create mode 100644
proxy/src/test/java/org/apache/rocketmq/proxy/common/RenewStrategyPolicyTest.java