From b822db062bd4aa163120e81290fbe24ef1caf7e8 Mon Sep 17 00:00:00 2001
From: zhangxu16 <zhangxu16@xiaomi.com>
Date: Wed, 14 Jul 2021 00:35:46 +0800
Subject: [PATCH] Fix DLQ can't be query sometimes

---
 .../apache/rocketmq/broker/processor/SendMessageProcessor.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
index 14ca4a5e..19a4f533 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
@@ -341,7 +341,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
                 int queueIdInt = Math.abs(this.random.nextInt() % 99999999) % DLQ_NUMS_PER_GROUP;
                 topicConfig = this.brokerController.getTopicConfigManager().createTopicInSendMessageBackMethod(newTopic,
                     DLQ_NUMS_PER_GROUP,
-                    PermName.PERM_WRITE, 0
+                    PermName.PERM_WRITE | PermName.PERM_READ, 0
                 );
                 msg.setTopic(newTopic);
                 msg.setQueueId(queueIdInt);
-- 
GitLab