mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-24 16:04:00 +08:00
[ISSUE #3949] Add enableTopicMessageTypeCheck
This commit is contained in:
@@ -95,6 +95,8 @@ public class ProxyConfig {
|
||||
|
||||
private boolean enableACL = false;
|
||||
|
||||
private boolean enableTopicMessageTypeCheck = true;
|
||||
|
||||
public boolean isEnablePrintJstack() {
|
||||
return enablePrintJstack;
|
||||
}
|
||||
@@ -502,4 +504,12 @@ public class ProxyConfig {
|
||||
public void setEnableACL(boolean enableACL) {
|
||||
this.enableACL = enableACL;
|
||||
}
|
||||
|
||||
public boolean isEnableTopicMessageTypeCheck() {
|
||||
return enableTopicMessageTypeCheck;
|
||||
}
|
||||
|
||||
public void setEnableTopicMessageTypeCheck(boolean enableTopicMessageTypeCheck) {
|
||||
this.enableTopicMessageTypeCheck = enableTopicMessageTypeCheck;
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user