This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new a32eca0fd4 [ISSUE #7932] Rectify the modifier order in namesrv
a32eca0fd4 is described below
commit a32eca0fd4085c99a061b1035dada9ec6caccecc
Author: oopooa <[email protected]>
AuthorDate: Sat Mar 16 11:51:49 2024 +0800
[ISSUE #7932] Rectify the modifier order in namesrv
---
namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java | 4 ++--
.../java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
index 179d3bb0d6..23d0906216 100644
--- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
+++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
@@ -43,8 +43,8 @@ import org.apache.rocketmq.srvutil.ShutdownHookThread;
public class NamesrvStartup {
- private final static Logger log =
LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);
- private final static Logger logConsole =
LoggerFactory.getLogger(LoggerName.NAMESRV_CONSOLE_LOGGER_NAME);
+ private static final Logger log =
LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);
+ private static final Logger logConsole =
LoggerFactory.getLogger(LoggerName.NAMESRV_CONSOLE_LOGGER_NAME);
private static Properties properties = null;
private static NamesrvConfig namesrvConfig = null;
private static NettyServerConfig nettyServerConfig = null;
diff --git
a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
index ce311d392a..d199283392 100644
---
a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
+++
b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
@@ -67,7 +67,7 @@ import
org.apache.rocketmq.remoting.protocol.statictopic.TopicQueueMappingInfo;
public class RouteInfoManager {
private static final Logger log =
LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);
- private final static long DEFAULT_BROKER_CHANNEL_EXPIRED_TIME = 1000 * 60
* 2;
+ private static final long DEFAULT_BROKER_CHANNEL_EXPIRED_TIME = 1000 * 60
* 2;
private final ReadWriteLock lock = new ReentrantReadWriteLock();
private final Map<String/* topic */, Map<String, QueueData>>
topicQueueTable;
private final Map<String/* brokerName */, BrokerData> brokerAddrTable;