(rocketmq) branch develop updated: [ISSUE #8534] Supports timer message queries (#8535)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 8b7f9cc5ef [ISSUE #8534] Supports timer message queries (#8535)
8b7f9cc5ef is described below

commit 8b7f9cc5ef4ae40b8834df6dd0fd1f09a7f454bb
Author: Lei Zhiyuan <leizhiy...@gmail.com>
AuthorDate: Tue Aug 20 11:09:07 2024 +0800

    [ISSUE #8534] Supports timer message queries (#8535)
---
 .../org/apache/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 d7c06180e9..c71c65fe8b 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.KVTable;
 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 @@ public class TopicConfigManager extends ConfigManager {
             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) {