You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2024/08/20 03:09:12 UTC
(rocketmq) branch develop updated: [ISSUE #8534] Supports timer message queries (#8535)
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 <le...@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) {