This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 527704d96 [ISSUE #5413] Modify AutoSwitchHAClient currentReceivedEpoch
attribute long type to int
add 58c79c9f1 [ISSUE #5365] [RIP 51] Add notification mechanism for pop
orderly (#5387)
No new revisions were added by this update.
Summary of changes:
.../offset/ConsumerOrderInfoLockManager.java | 185 +++++++++++++++
.../broker/offset/ConsumerOrderInfoManager.java | 26 +++
.../broker/processor/PopMessageProcessor.java | 33 ++-
...ConsumerOrderInfoManagerLockFreeNotifyTest.java | 173 ++++++++++++++
.../org/apache/rocketmq/common/BrokerConfig.java | 9 +
store/BUILD.bazel | 1 +
.../test/client/consumer/pop/BasePopOrderly.java | 38 +++-
.../pop/ChangeInvisibleTimeMidMsgOrderlyIT.java | 102 ---------
.../test/client/consumer/pop/PopOrderlyIT.java | 251 +++++++++++++++++++++
9 files changed, 708 insertions(+), 110 deletions(-)
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManagerLockFreeNotifyTest.java
delete mode 100644
test/src/test/java/org/apache/rocketmq/test/client/consumer/pop/ChangeInvisibleTimeMidMsgOrderlyIT.java
create mode 100644
test/src/test/java/org/apache/rocketmq/test/client/consumer/pop/PopOrderlyIT.java
