duhenglucky closed pull request #649: [ISSUE#525]add a switch
variable(traceTopicEnable) for making msg trace worked which is decided by
users and rename enableAcl flag variable.
URL: https://github.com/apache/rocketmq/pull/649
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git
a/acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionLoader.java
b/acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionLoader.java
index 14b25253e..1b8269332 100644
--- a/acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionLoader.java
+++ b/acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionLoader.java
@@ -119,7 +119,6 @@ public void run() {
&&
(StandardWatchEventKinds.ENTRY_MODIFY.equals(event.kind())
||
StandardWatchEventKinds.ENTRY_CREATE.equals(event.kind()))) {
log.info("{} make a difference change is
: {}", watchFileName, event.toString());
- //TODO do a retain
//Clearing the info, may result in a
non-available time
PlainPermissionLoader.this.clearPermissionInfo();
initialize();
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
index 73ed7eb4c..c3431ca41 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -492,7 +492,7 @@ private void initialTransaction() {
}
private void initialAcl() {
- if (!this.brokerConfig.isEnableAcl()) {
+ if (!this.brokerConfig.isAclEnable()) {
log.info("The broker dose not enable acl");
return;
}
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
index 6a97c1c7f..ed353da4b 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
@@ -125,12 +125,14 @@ public TopicConfigManager(BrokerController
brokerController) {
this.topicConfigTable.put(topicConfig.getTopicName(), topicConfig);
}
{
- String topic =
this.brokerController.getBrokerConfig().getMsgTraceTopicName();
- TopicConfig topicConfig = new TopicConfig(topic);
- this.systemTopicList.add(topic);
- topicConfig.setReadQueueNums(1);
- topicConfig.setWriteQueueNums(1);
- this.topicConfigTable.put(topicConfig.getTopicName(), topicConfig);
+ if (this.brokerController.getBrokerConfig().isTraceTopicEnable()) {
+ String topic =
this.brokerController.getBrokerConfig().getMsgTraceTopicName();
+ TopicConfig topicConfig = new TopicConfig(topic);
+ this.systemTopicList.add(topic);
+ topicConfig.setReadQueueNums(1);
+ topicConfig.setWriteQueueNums(1);
+ this.topicConfigTable.put(topicConfig.getTopicName(),
topicConfig);
+ }
}
}
diff --git a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
index f9d403ec5..1c3f37d00 100644
--- a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
+++ b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
@@ -53,6 +53,8 @@
private String messageStorePlugIn = "";
@ImportantField
private String msgTraceTopicName = MixAll.RMQ_SYS_TRACE_TOPIC;
+ @ImportantField
+ private boolean traceTopicEnable = false;
/**
* thread numbers for send message thread pool, since spin lock will be
used by default since 4.0.x, the default
* value is 1.
@@ -176,8 +178,7 @@
* Acl feature switch
*/
@ImportantField
- private boolean enableAcl = false;
-
+ private boolean aclEnable = false;
public static String localHostName() {
try {
@@ -717,14 +718,6 @@ public void setTransactionCheckInterval(long
transactionCheckInterval) {
this.transactionCheckInterval = transactionCheckInterval;
}
- public boolean isEnableAcl() {
- return enableAcl;
- }
-
- public void setEnableAcl(boolean isAclPlug) {
- this.enableAcl = isAclPlug;
- }
-
public int getEndTransactionThreadPoolNums() {
return endTransactionThreadPoolNums;
}
@@ -756,5 +749,20 @@ public String getMsgTraceTopicName() {
public void setMsgTraceTopicName(String msgTraceTopicName) {
this.msgTraceTopicName = msgTraceTopicName;
}
+
+ public boolean isTraceTopicEnable() {
+ return traceTopicEnable;
+ }
+
+ public void setTraceTopicEnable(boolean traceTopicEnable) {
+ this.traceTopicEnable = traceTopicEnable;
+ }
+ public boolean isAclEnable() {
+ return aclEnable;
+ }
+
+ public void setAclEnable(boolean aclEnable) {
+ this.aclEnable = aclEnable;
+ }
}
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
