You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/09/23 02:28:28 UTC
[rocketmq] branch release-5.0.0 updated (ac82378ae -> 251fc7795)
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a change to branch release-5.0.0
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from ac82378ae [maven-release-plugin] prepare for next development iteration
add 6f75e3d69 [ISSUE #5069] polish the startup of proxy; can specify parameters on the command line of proxy (#5083)
add 778513c56 [ISSUE #5097] fix illegal reflective access (#5098)
add 8615007f0 Sync DLedger version in Bazel scripts (#5102)
add 8ef88670a Sync commons-lang3 version (#5103)
add c185c60b0 [ISSUE #5108] Bump checkstyle to 3.2.0 (#5109)
add 45937936b Fixed intermixing of punctuation marks in English documents (#5086)
add 54d6580f6 [ISSUE #5104] Clean property PROPERTY_TIMER_DELAY_MS if not timer message #
add bfe8f423e Update FileRegionEncoder.java (#5111)
add b24ce7286 [ISSUE #5106]Make ProxyStartupTest portable (#5107)
add 8f4d925a1 Update pom.xml (#5115)
add 9b95b9e6c Update deploy_guide.md (#5099)
add 6813fdf30 Bump snakeyaml from 1.30 to 1.31 (#5084)
add d1ca7744d [ISSUE #5047] Modify MessageStoreConfig attribute maxTopicLength default value (#5048)
add b50f55f85 [ISSUE #5100] Recover the optimization of pull request #2885 (#5101)
add b511e0977 [ISSUE #5095] [Remoting-A] Support logging rpc distribution in remoting protocol (#5114)
add 7c6dbd7f3 [ISSUE #5116]Make PlainAccessControlFlowTest portable (#5117)
add b7bec238b [ISSUE #5091] Speed up broker initialization by concurrently loading ConsumeQueue (#5093)
add 96f340d6e [ISSUE #5119]Infra enhancement project: Fix remaining test cases in ACL module (#5120)
add 44aea94fd [ISSUE#5039] localHostName() get stuck when constructing the BrokerIdentity object (#5110)
add 39df11994 [ISSUE #5124] Revert signatures of public methods in 'org.apache.rocketmq.namesrv.NamesrvStartup'
add d5170e5ba [ISSUE #5089] Delegate plugin store configuration by broker
add a7b2cc367 Use StandardCharsets.UTF_8 as default charset of getting bytes when sending example messages (#5140)
add 4d0de5d18 delete PullConsumer.Test (#5139)
add 2bee9d81a [ISSUE #5131] Close the producer after the message is sent
add 808a747ce [ISSUE #5133] Use StandardCharsets.UTF_8 as default charset in oneway producer demo
add a4296a648 [ISSUE #5135] Format ERROR_MESSAGE string
add 91f98f3d5 remove unnecessary parameters (#5143)
add d0bd6a6c6 [ISSUE #5130] Use the latest rocketmq version as example in readme file (#5146)
add 4fcacb60d [ISSUE #5095] Support output thread exception information to the error log (#5129)
add 913527a08 [ISSUE #5149] remove:org/apache/rocketmq/example/simple/TestProducer.java
add aa330615f [ISSUE #4634] fix code style in namesrv module (#5159)
add 7e6bee2c4 Update description about remoting-based SDK (#5164)
add 251fc7795 Merge branch 'develop' into release-5.0.0
No new revisions were added by this update.
Summary of changes:
README.md | 10 +-
WORKSPACE | 1 +
acl/BUILD.bazel | 44 ++---
acl/pom.xml | 5 +
.../rocketmq/acl/plain/PlainPermissionManager.java | 9 +-
.../apache/rocketmq/acl/plain/AclTestHelper.java | 116 +++++++++++++
.../acl/plain/PlainAccessControlFlowTest.java | 188 ++++++---------------
.../acl/plain/PlainAccessValidatorTest.java | 35 ++--
.../acl/plain/PlainPermissionManagerTest.java | 70 ++------
.../apache/rocketmq/broker/BrokerController.java | 6 +-
.../org/apache/rocketmq/broker/util/HookUtils.java | 19 +--
.../org/apache/rocketmq/common/BrokerConfig.java | 20 +++
.../org/apache/rocketmq/common/BrokerIdentity.java | 25 ++-
.../java/org/apache/rocketmq/common/MixAll.java | 15 +-
.../apache/rocketmq/common/ThreadFactoryImpl.java | 12 ++
distribution/conf/logback_broker.xml | 26 +++
distribution/conf/logback_namesrv.xml | 26 +++
docs/cn/README.md | 2 +-
docs/en/proxy/deploy_guide.md | 15 +-
.../example/namespace/ProducerWithNamespace.java | 4 +-
.../rocketmq/example/simple/OnewayProducer.java | 5 +-
.../apache/rocketmq/example/simple/Producer.java | 7 +-
.../rocketmq/example/simple/PullConsumerTest.java | 48 ------
.../rocketmq/example/simple/TestProducer.java | 54 ------
.../apache/rocketmq/namesrv/NamesrvStartup.java | 19 ++-
.../rocketmq/namesrv/kvconfig/KVConfigManager.java | 12 +-
.../namesrv/processor/DefaultRequestProcessor.java | 6 +-
.../rocketmq/namesrv/route/ZoneRouteRPCHook.java | 3 +-
.../namesrv/routeinfo/RouteInfoManager.java | 9 +-
pom.xml | 12 +-
proxy/BUILD.bazel | 86 +++++-----
proxy/pom.xml | 5 +
.../apache/rocketmq/proxy/ProxyStartupTest.java | 84 ++++++++-
remoting/pom.xml | 5 +-
.../rocketmq/remoting/common/RemotingHelper.java | 1 +
.../rocketmq/remoting/netty/FileRegionEncoder.java | 7 +-
.../remoting/netty/NettyRemotingServer.java | 38 ++++-
.../netty/RemotingCodeDistributionHandler.java | 100 +++++++++++
.../netty/RemotingCodeDistributionHandlerTest.java | 80 +++++++++
.../org/apache/rocketmq/store/ConsumeQueue.java | 1 +
.../apache/rocketmq/store/DefaultMessageStore.java | 52 ++++--
.../rocketmq/store/config/MessageStoreConfig.java | 8 +-
.../rocketmq/store/ha/GroupTransferService.java | 130 +++++++-------
.../apache/rocketmq/store/ha/WaitNotifyObject.java | 68 ++++----
.../store}/plugin/AbstractPluginMessageStore.java | 2 +-
.../store}/plugin/MessageStoreFactory.java | 91 +++++-----
.../store}/plugin/MessageStorePluginContext.java | 126 +++++++-------
.../rocketmq/store/queue/ConsumeQueueStore.java | 79 ++++++++-
.../apache/rocketmq/tools/command/CommandUtil.java | 3 +-
.../rocketmq/tools/command/MQAdminStartup.java | 2 +-
50 files changed, 1093 insertions(+), 698 deletions(-)
create mode 100644 acl/src/test/java/org/apache/rocketmq/acl/plain/AclTestHelper.java
delete mode 100644 example/src/main/java/org/apache/rocketmq/example/simple/PullConsumerTest.java
delete mode 100644 example/src/main/java/org/apache/rocketmq/example/simple/TestProducer.java
create mode 100644 remoting/src/main/java/org/apache/rocketmq/remoting/netty/RemotingCodeDistributionHandler.java
create mode 100644 remoting/src/test/java/org/apache/rocketmq/remoting/netty/RemotingCodeDistributionHandlerTest.java
rename {broker/src/main/java/org/apache/rocketmq/broker => store/src/main/java/org/apache/rocketmq/store}/plugin/AbstractPluginMessageStore.java (99%)
rename {broker/src/main/java/org/apache/rocketmq/broker => store/src/main/java/org/apache/rocketmq/store}/plugin/MessageStoreFactory.java (87%)
rename {broker/src/main/java/org/apache/rocketmq/broker => store/src/main/java/org/apache/rocketmq/store}/plugin/MessageStorePluginContext.java (73%)