[rocketmq] branch develop updated: BugFix: Make internal logger additivitiy configurable

[li...@apache.org]

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 <li...@gmail.com>
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
lizhanhui@apache.org.