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 <41882826+oop...@users.noreply.github.com> 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;