Skip to content

Commit bafb63c

Browse files
committed
feat: make jul to SLF4J take effect
1 parent 2791833 commit bafb63c

File tree

4 files changed

+19
-0
lines changed

4 files changed

+19
-0
lines changed

broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@
3737
import org.apache.rocketmq.logging.org.slf4j.Logger;
3838
import org.apache.rocketmq.logging.org.slf4j.LoggerFactory;
3939
import org.apache.rocketmq.remoting.netty.NettyClientConfig;
40+
import org.slf4j.bridge.SLF4JBridgeHandler;
4041
import org.apache.rocketmq.remoting.netty.NettyServerConfig;
4142
import org.apache.rocketmq.remoting.protocol.RemotingCommand;
4243
import org.apache.rocketmq.srvutil.ServerUtil;
@@ -49,6 +50,10 @@ public class BrokerStartup {
4950
public static final SystemConfigFileHelper CONFIG_FILE_HELPER = new SystemConfigFileHelper();
5051

5152
public static void main(String[] args) {
53+
// Bridge java.util.logging to SLF4J
54+
SLF4JBridgeHandler.removeHandlersForRootLogger();
55+
SLF4JBridgeHandler.install();
56+
5257
start(createBrokerController(args));
5358
}
5459

namesrv/pom.xml

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,10 @@
4848
<groupId>${project.groupId}</groupId>
4949
<artifactId>rocketmq-srvutil</artifactId>
5050
</dependency>
51+
<dependency>
52+
<groupId>org.slf4j</groupId>
53+
<artifactId>jul-to-slf4j</artifactId>
54+
</dependency>
5155
<dependency>
5256
<groupId>org.openjdk.jmh</groupId>
5357
<artifactId>jmh-core</artifactId>

namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@
4040
import org.apache.rocketmq.logging.org.slf4j.LoggerFactory;
4141
import org.apache.rocketmq.srvutil.ServerUtil;
4242
import org.apache.rocketmq.srvutil.ShutdownHookThread;
43+
import org.slf4j.bridge.SLF4JBridgeHandler;
4344

4445
public class NamesrvStartup {
4546

@@ -52,6 +53,10 @@ public class NamesrvStartup {
5253
private static ControllerConfig controllerConfig = null;
5354

5455
public static void main(String[] args) {
56+
// Bridge java.util.logging to SLF4J
57+
SLF4JBridgeHandler.removeHandlersForRootLogger();
58+
SLF4JBridgeHandler.install();
59+
5560
main0(args);
5661
controllerManagerMain();
5762
}

proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@
4747
import org.apache.rocketmq.proxy.service.cert.TlsCertificateManager;
4848
import org.apache.rocketmq.remoting.protocol.RemotingCommand;
4949
import org.apache.rocketmq.srvutil.ServerUtil;
50+
import org.slf4j.bridge.SLF4JBridgeHandler;
5051

5152
import java.util.Date;
5253
import java.util.List;
@@ -65,6 +66,10 @@ public void appendStartAndShutdown(StartAndShutdown startAndShutdown) {
6566
}
6667

6768
public static void main(String[] args) {
69+
// Bridge java.util.logging to SLF4J
70+
SLF4JBridgeHandler.removeHandlersForRootLogger();
71+
SLF4JBridgeHandler.install();
72+
6873
try {
6974
// parse argument from command line
7075
CommandLineArgument commandLineArgument = parseCommandLineArgument(args);

0 commit comments

Comments
 (0)