This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch dledger-controller-snapshot
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from dabdfc177 [ISSUE #5585] Add snapshotable metadata manager interface
(#5598)
add 727865350 [ISSUE #5576]Optimize UtilAll#getPid method (#5582)
add f17112963 Optimize the build of sendMessageContext and avoid
unnecessary repeated request parsing (#5578)
add fdd77d1a0 [ISSUE #5562]Reset consumeOffset execution logic In a catch
blockļ¼and is not executed under normal circumstances (#5563)
add 93e82c820 [ISSUE #5569]Support broker priority election for controller
mode (#5548)
add ffb4a3664 Apply MDC in broker container mode (#5587)
add 08dbe7ede fix flaky test (#5591)
add 6f49a1034 Enable AbortProcessException to interrupt RPCHook (#5594)
new ad13f0ef2 Merge remote-tracking branch 'origin/develop' into
dledger-controller-snapshot
The 1 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 | 6 +-
.../rocketmq/broker/BrokerPreOnlineService.java | 2 +-
.../client/DefaultConsumerIdsChangeListener.java | 2 +-
.../broker/filtersrv/FilterServerManager.java | 2 +-
.../rocketmq/broker/latency/BrokerFastFailure.java | 2 +-
.../longpolling/LmqPullRequestHoldService.java | 2 +-
.../broker/longpolling/PullRequestHoldService.java | 2 +-
.../apache/rocketmq/broker/out/BrokerOuterAPI.java | 10 +-
.../processor/AbstractSendMessageProcessor.java | 2 +-
.../broker/processor/NotificationProcessor.java | 2 +-
.../broker/processor/PopBufferMergeService.java | 2 +-
.../broker/processor/PopMessageProcessor.java | 4 +-
.../broker/processor/PopReviveService.java | 2 +-
.../broker/processor/PullMessageProcessor.java | 2 +-
.../broker/processor/SendMessageProcessor.java | 2 +-
.../topic/TopicQueueMappingCleanService.java | 2 +-
.../TransactionalMessageCheckService.java | 2 +-
broker/src/main/resources/rmq.broker.logback.xml | 667 ++++++++++++---------
.../broker/processor/SendMessageProcessorTest.java | 2 +-
.../rocketmq/common}/AbortProcessException.java | 5 +-
.../rocketmq/common/AbstractBrokerRunnable.java | 18 +-
.../org/apache/rocketmq/common/BrokerIdentity.java | 8 +-
.../apache/rocketmq/common/ThreadFactoryImpl.java | 2 +-
.../apache/rocketmq/container/BrokerContainer.java | 6 +-
.../rocketmq/container/BrokerContainerStartup.java | 2 +-
.../rocketmq/container/InnerBrokerController.java | 4 +-
docs/cn/BrokerContainer.md | 31 +-
.../remoting/netty/NettyRemotingAbstract.java | 34 +-
.../rocketmq/store/AllocateMappedFileService.java | 2 +-
.../java/org/apache/rocketmq/store/CommitLog.java | 8 +-
.../apache/rocketmq/store/DefaultMessageStore.java | 18 +-
.../apache/rocketmq/store/StoreStatsService.java | 2 +-
.../apache/rocketmq/store/ha/DefaultHAClient.java | 2 +-
.../rocketmq/store/ha/DefaultHAConnection.java | 4 +-
.../apache/rocketmq/store/ha/DefaultHAService.java | 2 +-
.../rocketmq/store/ha/GroupTransferService.java | 2 +-
.../ha/HAConnectionStateNotificationService.java | 2 +-
.../store/ha/autoswitch/AutoSwitchHAClient.java | 2 +-
.../ha/autoswitch/AutoSwitchHAConnection.java | 4 +-
.../store/ha/autoswitch/AutoSwitchHAService.java | 2 +-
.../apache/rocketmq/store/index/IndexService.java | 2 +-
.../rocketmq/store/kv/CompactionService.java | 2 +-
.../rocketmq/store/timer/TimerMessageStore.java | 14 +-
.../org/apache/rocketmq/store/ha/HAServerTest.java | 2 +-
.../org/apache/rocketmq/test/util/VerifyUtils.java | 11 +-
.../rocketmq/test/delay/NormalMsgDelayIT.java | 11 +-
46 files changed, 514 insertions(+), 405 deletions(-)
rename {broker/src/main/java/org/apache/rocketmq/broker/mqtrace =>
common/src/main/java/org/apache/rocketmq/common}/AbortProcessException.java
(95%)
