diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java index 5b15d7953c8..96daa46f957 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java @@ -65,6 +65,7 @@ public static BrokerController start(BrokerController controller) { log.info(tip); return controller; } catch (Throwable e) { + System.out.printf("Broker startup failure with following exceptions:"); e.printStackTrace(); System.exit(-1); } @@ -176,6 +177,7 @@ public static BrokerController createBrokerController(String[] args) { } messageStoreConfig.setHaListenPort(nettyServerConfig.getListenPort() + 1); + LoggerContext lc = (LoggerContext) LoggerFactory.getILoggerFactory(); JoranConfigurator configurator = new JoranConfigurator(); configurator.setContext(lc); diff --git a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java index 5dd15dd5320..07ab47917c7 100644 --- a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java +++ b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java @@ -156,6 +156,7 @@ public void run() { return controller; } catch (Throwable e) { + System.out.printf("Filtersrv startup failure with following exceptions:"); e.printStackTrace(); System.exit(-1); } diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java index 4fa97ad0a45..c37e1b18dbd 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java @@ -149,7 +149,9 @@ public void run() { System.out.printf(tip + "%n"); return controller; - } catch (Throwable e) { + } + catch (Throwable e) { + System.out.printf("Namesrv startup failure with following exceptions:"); e.printStackTrace(); System.exit(-1); } diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java b/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java index fdf8e219d6d..6a0c3edab8b 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java @@ -132,6 +132,7 @@ public static void main0(String[] args, RPCHook rpcHook) { break; } } catch (Exception e) { + System.out.printf("MQAdmin startup failure with following exceptions:"); e.printStackTrace(); } }