opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-29 04:13:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #8950] Remove Redundant nullcheck of configPath (#8951)

Browse Source 
Co-authored-by: jiaoja <jiaoja@asiainfo.com>
This commit is contained in:
jiao jianan
2024-12-02 10:03:16 +08:00
committed by GitHub
parent fb3b87da1b
commit 93d7e80a97
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
+2 -5
View File
@@ -86,7 +86,7 @@ public class BrokerContainerProcessor implements NettyRequestProcessor {
}
private synchronized RemotingCommand addBroker(ChannelHandlerContext ctx,
RemotingCommand request) throws Exception {
RemotingCommand request) throws Exception {
final RemotingCommand response = RemotingCommand.createResponseCommand(null);
final AddBrokerRequestHeader requestHeader = (AddBrokerRequestHeader) request.decodeCommandCustomHeader(AddBrokerRequestHeader.class);
@@ -124,10 +124,7 @@ public class BrokerContainerProcessor implements NettyRequestProcessor {
MixAll.properties2Object(brokerProperties, messageStoreConfig);
messageStoreConfig.setHaListenPort(brokerConfig.getListenPort() + 1);
if (configPath != null && !configPath.isEmpty()) {
brokerConfig.setBrokerConfigPath(configPath);
}
brokerConfig.setBrokerConfigPath(configPath);
if (!messageStoreConfig.isEnableDLegerCommitLog()) {
if (!brokerConfig.isEnableControllerMode()) {