|
@@ -326,7 +326,13 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
LOGGER.info("sendGroupMessage groupSend ret={}", JSON.toJSONString(imMessageDto));
|
|
|
//ExecutorService executor = Executors.newCachedThreadPool();
|
|
|
CompletableFuture.runAsync(()->{
|
|
|
- imFeignService.groupSend(imMessageDto);
|
|
|
+ Object ret;
|
|
|
+ int maxRetry = 3;
|
|
|
+ do {
|
|
|
+ // 若发送失败,重试3次后放弃
|
|
|
+ ret = imFeignService.groupSend(imMessageDto);
|
|
|
+ LOGGER.info("sendGroupMessage groupSend retry={}, ret={}", maxRetry, JSON.toJSONString(ret));
|
|
|
+ } while (ret == null && maxRetry-- > 0);
|
|
|
});
|
|
|
}
|
|
|
|