mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-30 18:10:44 +08:00
This commit is contained in:
@@ -29,6 +29,7 @@ import org.apache.commons.cli.CommandLine;
|
||||
import org.apache.commons.cli.Option;
|
||||
import org.apache.commons.cli.Options;
|
||||
import org.apache.commons.cli.PosixParser;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.apache.rocketmq.common.MixAll;
|
||||
import org.apache.rocketmq.common.constant.LoggerName;
|
||||
import org.apache.rocketmq.common.ControllerConfig;
|
||||
@@ -109,6 +110,11 @@ public class ControllerStartup {
|
||||
JoranConfigurator configurator = new JoranConfigurator();
|
||||
configurator.setContext(lc);
|
||||
lc.reset();
|
||||
|
||||
if (StringUtils.isEmpty(controllerConfig.getRocketmqHome())) {
|
||||
System.out.printf("Please set the %s or %s variable in your environment!%n", MixAll.ROCKETMQ_HOME_ENV, MixAll.ROCKETMQ_HOME_PROPERTY);
|
||||
System.exit(-1);
|
||||
}
|
||||
configurator.doConfigure(controllerConfig.getRocketmqHome() + "/conf/logback_controller.xml");
|
||||
|
||||
log = InternalLoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);
|
||||
|
||||
Reference in New Issue
Block a user