five-groups
/
five-groups-couplet
4
0
Fork 0
Code Issues Pull Requests 2 Packages Projects Releases Wiki Activity

Merge branch 'server_five' of https://gitea.qinmian.online/five-groups/five-groups-couplet into server_five_liuyunhu

server_five_liuyunhu
liuyunhu 2024-04-06 10:56:16 +08:00
parent 64caa2296c 5184d57407
commit 9b0121446a
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/consumer/FenceConsumer.java
View File

@ -68,7 +68,6 @@ public class FenceConsumer {
log.error("消息已丢失,已再次传入的信息是:【{}】", fenceUpdateRequest); log.error("消息已丢失,已再次传入的信息是:【{}】", fenceUpdateRequest);
channel.basicNack(deliveryTag, true, false); channel.basicNack(deliveryTag, true, false);
} }
} }

11
couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java
View File

@ -110,11 +110,12 @@ public class ModelMessage {
IncidentService incidentService = SpringUtils.getBean(string); IncidentService incidentService = SpringUtils.getBean(string);
incidentService.incident(msgData); incidentService.incident(msgData);
} }
try { // 不睡眠，他们也会主动拉取数据，不会影响其他服务
Thread.sleep(1000); // try {
} catch (InterruptedException e) { // Thread.sleep(1000);
throw new RuntimeException(e); // } catch (InterruptedException e) {
} // throw new RuntimeException(e);
// }
} }
} }