提交 0a16ff6a 编写于 作者: Z zhangxu16

DLQ topic default perm change

上级 9f95a972
...@@ -188,7 +188,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement ...@@ -188,7 +188,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
topicConfig = this.brokerController.getTopicConfigManager().createTopicInSendMessageBackMethod(newTopic, topicConfig = this.brokerController.getTopicConfigManager().createTopicInSendMessageBackMethod(newTopic,
DLQ_NUMS_PER_GROUP, DLQ_NUMS_PER_GROUP,
PermName.PERM_WRITE, 0); PermName.PERM_WRITE | PermName.PERM_READ, 0);
if (null == topicConfig) { if (null == topicConfig) {
response.setCode(ResponseCode.SYSTEM_ERROR); response.setCode(ResponseCode.SYSTEM_ERROR);
response.setRemark("topic[" + newTopic + "] not exist"); response.setRemark("topic[" + newTopic + "] not exist");
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册