From a26981a92ee6ebe80f680212bead38c29ce363ce Mon Sep 17 00:00:00 2001
From: qiminbao <qaz001122>
Date: Mon, 27 Oct 2025 10:26:29 +0800
Subject: [PATCH] =?UTF-8?q?v1.1=E5=88=9D=E5=A7=8B=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../server/rockermq/listener/AgentConsumerDownListener.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java b/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
index e62b1ca..3674d32 100644
--- a/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
+++ b/src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
@@ -18,7 +18,7 @@ import java.util.Objects;
 
 @Component
 @ConditionalOnProperty(name = "rocketmq.enabled", havingValue = "true")
-@RocketMQMessageListener(topic = "tongran_agent_down", consumerGroup = "tongran_agent_down_group")
+@RocketMQMessageListener(topic = "tr_agent_down", consumerGroup = "tr_agent_down_group")
 public class AgentConsumerDownListener implements RocketMQListener<String> {
 
 	protected final SessionManager sessionManager;