wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3282: 处理异常

Browse Source
This commit is contained in:
yanglin 2024-12-23 11:10:27 +08:00
parent a735bc076d
commit 823b58045f
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
inside-notices/src/main/java/cn/axzo/msg/center/message/service/card/CardManager.java
View File

@ -91,9 +91,9 @@ public class CardManager {
sendLogger.reloadAndLogCards("send:enqueue"); sendLogger.reloadAndLogCards("send:enqueue");
}); });
PushDeviceSnapshots deviceSnapshots = pushDeviceService.createDeviceSnapshots(); PushDeviceSnapshots deviceSnapshots = pushDeviceService.createDeviceSnapshots();
CardSendExecutor batchExecutor = new CardSendExecutor(request, executor); CardSendExecutor groupExecutor = new CardSendExecutor(request, executor);
for (CardGroup group : sendModel.getCardGroups()) { for (CardGroup group : sendModel.getCardGroups()) {
batchExecutor.submit(() -> { groupExecutor.submit(() -> {
SendTemplateMessageParam imRequest = cardSupport.buildImSendRequest( SendTemplateMessageParam imRequest = cardSupport.buildImSendRequest(
sendModel, group, deviceSnapshots); sendModel, group, deviceSnapshots);
CardLogger groupLogger = cardLoggers.createLogger(requestContext, group.getCards()); CardLogger groupLogger = cardLoggers.createLogger(requestContext, group.getCards());
@ -113,7 +113,7 @@ public class CardManager {
}); });
} }
try { try {
batchExecutor.awaitTermination(5, TimeUnit.MINUTES); groupExecutor.awaitTermination(5, TimeUnit.MINUTES);
} catch (Exception e) { } catch (Exception e) {
log.warn("发送IM消息失败, deleteCardsWhenSendFail={}, request={}", log.warn("发送IM消息失败, deleteCardsWhenSendFail={}, request={}",
cardProps.isDeleteCardsWhenSendFail(), request, e); cardProps.isDeleteCardsWhenSendFail(), request, e);