[rocketmq] branch develop updated (8d28d3f -> 14b63ee)

[ji...@apache.org]

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 8d28d3f  [ISSUE #3751] docs: Fix typos and other little error in the document 'Configuration_Client.md' (#3752)
     add 14b63ee  [RIP-28] light message queue(LMQ)  (#3694)

No new revisions were added by this update.

Summary of changes:
 .../apache/rocketmq/broker/BrokerController.java   |  16 +-
 .../rocketmq/broker/BrokerPathConfigHelper.java    |   4 +
 .../longpolling/LmqPullRequestHoldService.java     |  62 +++
 .../broker/longpolling/ManyPullRequest.java        |   4 +
 .../broker/longpolling/PullRequestHoldService.java |   8 +-
 .../broker/offset/ConsumerOffsetManager.java       |   6 +-
 .../broker/offset/LmqConsumerOffsetManager.java    | 109 +++++
 .../broker/plugin/AbstractPluginMessageStore.java  | 539 +++++++++++----------
 .../broker/processor/AdminBrokerProcessor.java     |   7 +
 .../broker/processor/SendMessageProcessor.java     |   4 +
 .../subscription/LmqSubscriptionGroupManager.java  |  46 ++
 .../broker/topic/LmqTopicConfigManager.java        |  49 ++
 .../broker/BrokerPathConfigHelperTest.java         |  42 ++
 .../offset/LmqConsumerOffsetManagerTest.java       |  81 ++++
 .../java/org/apache/rocketmq/common/MixAll.java    |   5 +
 .../rocketmq/common/message/MessageConst.java      |   3 +
 .../org/apache/rocketmq/common/MixAllTest.java     |  12 +
 docs/cn/Example_LMQ.md                             |  85 ++++
 docs/cn/image/LMQ_1.png                            | Bin 0 -> 304040 bytes
 .../java/org/apache/rocketmq/store/CommitLog.java  |  24 +
 .../org/apache/rocketmq/store/ConsumeQueue.java    |  56 ++-
 .../apache/rocketmq/store/DefaultMessageStore.java | 114 ++++-
 .../org/apache/rocketmq/store/MessageStore.java    |  10 +
 .../org/apache/rocketmq/store/MultiDispatch.java   | 157 ++++++
 .../apache/rocketmq/store/PutMessageStatus.java    |   1 +
 .../rocketmq/store/config/MessageStoreConfig.java  |  28 ++
 .../store/stats/LmqBrokerStatsManager.java         | 120 +++++
 .../apache/rocketmq/store/ConsumeQueueTest.java    | 139 ++++++
 .../rocketmq/store/DefaultMessageStoreTest.java    |  16 +
 .../apache/rocketmq/store/MultiDispatchTest.java   |  98 ++++
 test/pom.xml                                       |  21 +
 .../rocketmq/test/lmq/benchmark/BenchLmqStore.java | 305 ++++++++++++
 .../org/apache/rocketmq/test/util/StatUtil.java    | 478 ++++++++++++++++++
 .../rocketmq/test/lmq/TestBenchLmqStore.java       | 100 ++++
 34 files changed, 2466 insertions(+), 283 deletions(-)
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/longpolling/LmqPullRequestHoldService.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/offset/LmqConsumerOffsetManager.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/topic/LmqTopicConfigManager.java
 create mode 100644 broker/src/test/java/org/apache/rocketmq/broker/BrokerPathConfigHelperTest.java
 create mode 100644 broker/src/test/java/org/apache/rocketmq/broker/offset/LmqConsumerOffsetManagerTest.java
 create mode 100644 docs/cn/Example_LMQ.md
 create mode 100644 docs/cn/image/LMQ_1.png
 create mode 100644 store/src/main/java/org/apache/rocketmq/store/MultiDispatch.java
 create mode 100644 store/src/main/java/org/apache/rocketmq/store/stats/LmqBrokerStatsManager.java
 create mode 100644 store/src/test/java/org/apache/rocketmq/store/MultiDispatchTest.java
 create mode 100644 test/src/main/java/org/apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java
 create mode 100644 test/src/main/java/org/apache/rocketmq/test/util/StatUtil.java
 create mode 100644 test/src/test/java/org/apache/rocketmq/test/lmq/TestBenchLmqStore.java