1.添加爬主播发送到AI消息队列

2025-09-25 21:52:43 +08:00
parent ca86db8f66
commit a4020b9176
1 changed files with 1 additions and 0 deletions
--- a/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java
+++ b/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java
@@ -79,6 +79,7 @@ public class HostInfoServiceImpl extends ServiceImpl<NewHostsMapper, NewHosts> i
                newHosts.forEach(newHost -> {
                    mqSender.send(newHost.getTenantId(),newHost);
                });
+                log.info("发送消息到队列{}, 消息数量: {}", newHosts.get(0).getTenantId(), newHosts.size());
            }