Fix DLQ can't be query sometimes

2026-10-30 18:44:38 +08:00 · 2021-07-14 00:35:46 +08:00
parent 0a16ff6a5f
commit b822db062b
1 changed files with 1 additions and 1 deletions
@@ -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);