This is an automated email from the ASF dual-hosted git repository.
ltamber pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from aa9ee1d059 [ISSUE #9689] Fix the issue that master transfer epoch was
not updated in time
add 7d7502126c [ISSUE #9719] Fix Static Variable Conflicts in Multi-Broker
Metrics Management (#9720)
No new revisions were added by this update.
Summary of changes:
.../apache/rocketmq/broker/BrokerController.java | 12 +-
.../broker/longpolling/PopLongPollingService.java | 4 +-
.../broker/metrics/BrokerMetricsManager.java | 21 +++-
.../rocketmq/broker/metrics/PopMetricsManager.java | 105 ++++++++++------
.../processor/AbstractSendMessageProcessor.java | 4 +-
.../broker/processor/AckMessageProcessor.java | 3 +-
.../processor/ChangeInvisibleTimeProcessor.java | 9 +-
.../processor/DefaultPullMessageResultHandler.java | 7 +-
.../broker/processor/PeekMessageProcessor.java | 7 +-
.../broker/processor/PopBufferMergeService.java | 7 +-
.../broker/processor/PopMessageProcessor.java | 18 +--
.../broker/processor/PopReviveService.java | 9 +-
.../broker/processor/PullMessageProcessor.java | 6 +-
.../broker/processor/QueryMessageProcessor.java | 14 ++-
.../broker/processor/AckMessageProcessorTest.java | 7 ++
.../ChangeInvisibleTimeProcessorTest.java | 61 +++++----
.../broker/processor/PopReviveServiceTest.java | 16 ++-
.../rocketmq/container/InnerBrokerController.java | 9 ++
.../apache/rocketmq/remoting/RemotingServer.java | 3 +
.../remoting/metrics/RemotingMetricsManager.java | 38 ++++--
.../remoting/netty/NettyRemotingAbstract.java | 133 ++++++++++++++++----
.../store/metrics/DefaultStoreMetricsManager.java | 9 +-
.../store/metrics/RocksDBStoreMetricsManager.java | 137 +++++++++++++++------
23 files changed, 455 insertions(+), 184 deletions(-)
