@@ -44,6 +44,8 @@ public class ClientLogger {
44
44
45
45
private static final boolean CLIENT_USE_SLF4J ;
46
46
47
+ private static Appender appenderProxy = new AppenderProxy ();
48
+
47
49
//private static Appender rocketmqClientAppender = null;
48
50
49
51
static {
@@ -53,6 +55,7 @@ public class ClientLogger {
53
55
CLIENT_LOGGER = createLogger (LoggerName .CLIENT_LOGGER_NAME );
54
56
createLogger (LoggerName .COMMON_LOGGER_NAME );
55
57
createLogger (RemotingHelper .ROCKETMQ_REMOTING );
58
+ Logger .getRootLogger ().addAppender (appenderProxy );
56
59
} else {
57
60
CLIENT_LOGGER = InternalLoggerFactory .getLogger (LoggerName .CLIENT_LOGGER_NAME );
58
61
}
@@ -76,7 +79,6 @@ private static synchronized Appender createClientAppender() {
76
79
.withRollingFileAppender (logFileName , maxFileSize , maxFileIndex )
77
80
.withAsync (false , queueSize ).withName (ROCKETMQ_CLIENT_APPENDER_NAME ).withLayout (layout ).build ();
78
81
79
- Logger .getRootLogger ().addAppender (rocketmqClientAppender );
80
82
return rocketmqClientAppender ;
81
83
}
82
84
@@ -91,7 +93,7 @@ private static InternalLogger createLogger(final String loggerName) {
91
93
// createClientAppender();
92
94
//}
93
95
94
- realLogger .addAppender (new AppenderProxy () );
96
+ realLogger .addAppender (appenderProxy );
95
97
realLogger .setLevel (Level .toLevel (clientLogLevel ));
96
98
realLogger .setAdditivity (additive );
97
99
return logger ;
0 commit comments