opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

isolate broker's log can be configured

Browse Source
This commit is contained in:
zhangjidi
2021-09-15 16:33:56 +08:00
parent 764cfba296
commit fc5180e6b1
2 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
+5 -2
View File
@@ -187,8 +187,11 @@ public class BrokerStartup {
JoranConfigurator configurator = new JoranConfigurator();
configurator.setContext(lc);
lc.reset();
System.setProperty("brokerLogDir", brokerConfig.getBrokerName() + "_" + brokerConfig.getBrokerId());
if (messageStoreConfig.isEnableDLegerCommitLog()) {
System.setProperty("brokerLogDir", "");
if (brokerConfig.isIsolateLogEnable()) {
System.setProperty("brokerLogDir", brokerConfig.getBrokerName() + "_" + brokerConfig.getBrokerId());
}
if (brokerConfig.isIsolateLogEnable() && messageStoreConfig.isEnableDLegerCommitLog()) {
System.setProperty("brokerLogDir", brokerConfig.getBrokerName() + "_" + messageStoreConfig.getdLegerSelfId());
}
configurator.doConfigure(brokerConfig.getRocketmqHome() + "/conf/logback_broker.xml");
common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
+10
View File
@@ -187,6 +187,8 @@ public class BrokerConfig {
private boolean autoDeleteUnusedStats = false;
private boolean isolateLogEnable = false;
public static String localHostName() {
try {
return InetAddress.getLocalHost().getHostName();
@@ -804,4 +806,12 @@ public class BrokerConfig {
public void setAutoDeleteUnusedStats(boolean autoDeleteUnusedStats) {
this.autoDeleteUnusedStats = autoDeleteUnusedStats;
}
public boolean isIsolateLogEnable() {
return isolateLogEnable;
}
public void setIsolateLogEnable(boolean isolateLogEnable) {
this.isolateLogEnable = isolateLogEnable;
}
}