This is an automated email from the ASF dual-hosted git repository.
lizhanhui 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 2e488e5 BugFix: Make internal logger additivitiy configurable
2e488e5 is described below
commit 2e488e531bf6331be89be7632023f9a858a6ddb9
Author: Li Zhanhui <[email protected]>
AuthorDate: Wed May 23 15:01:10 2018 +0800
BugFix: Make internal logger additivitiy configurable
---
client/src/main/java/org/apache/rocketmq/client/log/ClientLogger.java | 3 +++
1 file changed, 3 insertions(+)
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 c0dbf32..c62b385 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
@@ -34,6 +34,7 @@ public class ClientLogger {
public static final String CLIENT_LOG_MAXINDEX =
"rocketmq.client.logFileMaxIndex";
public static final String CLIENT_LOG_FILESIZE =
"rocketmq.client.logFileMaxSize";
public static final String CLIENT_LOG_LEVEL = "rocketmq.client.logLevel";
+ public static final String CLIENT_LOG_ADDITIVE =
"rocketmq.client.log.additive";
public static final String CLIENT_LOG_FILENAME =
"rocketmq.client.logFileName";
public static final String CLIENT_LOG_ASYNC_QUEUESIZE =
"rocketmq.client.logAsyncQueueSize";
public static final String ROCKETMQ_CLIENT_APPENDER_NAME =
"RocketmqClientAppender";
@@ -79,6 +80,7 @@ public class ClientLogger {
private static InternalLogger createLogger(final String loggerName) {
String clientLogLevel = System.getProperty(CLIENT_LOG_LEVEL, "INFO");
+ boolean additive =
"true".equalsIgnoreCase(System.getProperty(CLIENT_LOG_ADDITIVE));
InternalLogger logger = InternalLoggerFactory.getLogger(loggerName);
InnerLoggerFactory.InnerLogger innerLogger =
(InnerLoggerFactory.InnerLogger) logger;
Logger realLogger = innerLogger.getLogger();
@@ -89,6 +91,7 @@ public class ClientLogger {
realLogger.addAppender(rocketmqClientAppender);
realLogger.setLevel(Level.toLevel(clientLogLevel));
+ realLogger.setAdditivity(additive);
return logger;
}
--
To stop receiving notification emails like this one, please contact
[email protected].
