Agent/tr-agent-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

初始化

Browse Source
This commit is contained in:
qiminbao
2025-09-10 15:49:12 +08:00
parent afecffc5db
commit 8272523126
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java
+1 -1
View File
@@ -25,7 +25,7 @@ import java.util.Objects;
@Component @Component
@ConditionalOnProperty(name = "rocketmq.enabled", havingValue = "true") @ConditionalOnProperty(name = "rocketmq.enabled", havingValue = "true")
@RocketMQMessageListener(topic = "agent_down", consumerGroup = "agent_down_group") @RocketMQMessageListener(topic = "tongran_agent_down", consumerGroup = "tongran_agent_down_group")
public class AgentConsumerDownListener implements RocketMQListener<String> { public class AgentConsumerDownListener implements RocketMQListener<String> {
protected final SessionManager sessionManager; protected final SessionManager sessionManager;