You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/08/01 04:38:39 UTC

[rocketmq] branch develop updated (e976cdbfc -> 3c36a19cb)

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


    from e976cdbfc [ISSUE #4739] Add TimerMessageStore runtime info in ClusterListSubCommand (#4740)
     new a9ab25439 Enable new timer message to adapt to ha switching and brokerContainer
     new 9a5f0efd4 Fix minor naming error
     new 773e1ac19 Add volatile to brokerRole in MessageStoreConfig
     new 1483d679d Merge branch 'develop' into develop-yy
     new 3c36a19cb Merge pull request #4733 from RongtongJin/develop-yy

The 7274 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:
 .../apache/rocketmq/broker/BrokerController.java   |  53 ++--
 .../broker/controller/ReplicasManager.java         |  11 +-
 .../broker/dledger/DLedgerRoleChangeHandler.java   |  10 +-
 .../apache/rocketmq/broker/out/BrokerOuterAPI.java |  39 +++
 .../rocketmq/broker/slave/SlaveSynchronize.java    |  41 +++
 .../rocketmq/common/protocol/RequestCode.java      |   4 +
 .../rocketmq/store/config/MessageStoreConfig.java  |   2 +-
 .../rocketmq/store/timer/TimerMessageStore.java    | 285 ++++++++++++---------
 8 files changed, 303 insertions(+), 142 deletions(-)