You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/03/19 09:57:10 UTC
[rocketmq] branch develop updated: [ISSUE #4000]Fix the warn log input in command tools (#4001)
This is an automated email from the ASF dual-hosted git repository.
duhengforever 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 6ff00ed [ISSUE #4000]Fix the warn log input in command tools (#4001)
6ff00ed is described below
commit 6ff00ed0530bbd94e6ed9cc444b0a2fdb57c7ba3
Author: zhangjidi2016 <10...@qq.com>
AuthorDate: Sat Mar 19 17:56:56 2022 +0800
[ISSUE #4000]Fix the warn log input in command tools (#4001)
Co-authored-by: zhangjidi <zh...@cmss.chinamobile.com>
---
.../src/main/java/org/apache/rocketmq/client/log/ClientLogger.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/log/ClientLogger.java b/client/src/main/java/org/apache/rocketmq/client/log/ClientLogger.java
index b40f6a5..7ee2eba 100644
--- a/client/src/main/java/org/apache/rocketmq/client/log/ClientLogger.java
+++ b/client/src/main/java/org/apache/rocketmq/client/log/ClientLogger.java
@@ -44,6 +44,8 @@ public class ClientLogger {
private static final boolean CLIENT_USE_SLF4J;
+ private static Appender appenderProxy = new AppenderProxy();
+
//private static Appender rocketmqClientAppender = null;
static {
@@ -53,6 +55,7 @@ public class ClientLogger {
CLIENT_LOGGER = createLogger(LoggerName.CLIENT_LOGGER_NAME);
createLogger(LoggerName.COMMON_LOGGER_NAME);
createLogger(RemotingHelper.ROCKETMQ_REMOTING);
+ Logger.getRootLogger().addAppender(appenderProxy);
} else {
CLIENT_LOGGER = InternalLoggerFactory.getLogger(LoggerName.CLIENT_LOGGER_NAME);
}
@@ -76,7 +79,6 @@ public class ClientLogger {
.withRollingFileAppender(logFileName, maxFileSize, maxFileIndex)
.withAsync(false, queueSize).withName(ROCKETMQ_CLIENT_APPENDER_NAME).withLayout(layout).build();
- Logger.getRootLogger().addAppender(rocketmqClientAppender);
return rocketmqClientAppender;
}
@@ -91,7 +93,7 @@ public class ClientLogger {
// createClientAppender();
//}
- realLogger.addAppender(new AppenderProxy());
+ realLogger.addAppender(appenderProxy);
realLogger.setLevel(Level.toLevel(clientLogLevel));
realLogger.setAdditivity(additive);
return logger;