From c903ccd1fe8d7a7d23c60a3fbe7bca2b29c67ed4 Mon Sep 17 00:00:00 2001
From: leizhiyuan <leizhiyuan@gmail.com>
Date: Wed, 14 Aug 2024 19:20:03 +0800
Subject: [PATCH] feat: supports timer message queries

---
 .../rocketmq/broker/topic/TopicConfigManager.java    | 12 ++++++++++++
 1 file changed, 12 insertions(+)

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 d7c06180e9e..c71c65fe8bd 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
@@ -52,6 +52,7 @@
 import org.apache.rocketmq.remoting.protocol.body.TopicConfigAndMappingSerializeWrapper;
 import org.apache.rocketmq.remoting.protocol.body.TopicConfigSerializeWrapper;
 import org.apache.rocketmq.remoting.protocol.statictopic.TopicQueueMappingInfo;
+import org.apache.rocketmq.store.timer.TimerMessageStore;
 import org.apache.rocketmq.tieredstore.TieredMessageStore;
 import org.apache.rocketmq.tieredstore.metadata.MetadataStore;
 import org.apache.rocketmq.tieredstore.metadata.entity.TopicMetadata;
@@ -211,6 +212,17 @@ protected void init() {
             topicConfig.setWriteQueueNums(1);
             putTopicConfig(topicConfig);
         }
+
+        {
+            if (this.brokerController.getMessageStoreConfig().isTimerWheelEnable()) {
+                String topic = TimerMessageStore.TIMER_TOPIC;
+                TopicConfig topicConfig = new TopicConfig(topic);
+                TopicValidator.addSystemTopic(topic);
+                topicConfig.setReadQueueNums(1);
+                topicConfig.setWriteQueueNums(1);
+                this.topicConfigTable.put(topicConfig.getTopicName(), topicConfig);
+            }
+        }
     }
 
     protected TopicConfig putTopicConfig(TopicConfig topicConfig) {