v1.1初始化

2025-10-27 10:26:29 +08:00
parent eb53489e90
commit a26981a92e
1 changed files with 1 additions and 1 deletions
@@ -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;