From 8cf7f885e6c346e2867a8bde3dca099e6482d796 Mon Sep 17 00:00:00 2001 From: byteblogs168 <598092184@qq.com> Date: Thu, 27 Jul 2023 23:22:01 +0800 Subject: [PATCH] =?UTF-8?q?feat:=202.0.3=201.=20=E5=8F=91=E5=B8=832.0.3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 14 ++++++++------ .../server/service/impl/RetryServiceImpl.java | 4 ++++ pom.xml | 2 +- 3 files changed, 13 insertions(+), 7 deletions(-) diff --git a/README.md b/README.md index 20963f2bd..bba94bfa9 100644 --- a/README.md +++ b/README.md @@ -7,7 +7,7 @@
- 分布式重试服务平台 Easy-Retry + 致力提高分布式业务系统一致性的分布式重试平台
@@ -41,14 +41,16 @@ ## 相关链接 - [字节跳动: 如何优雅地重试](https://juejin.cn/post/6914091859463634951) -- [文档](https://www.easyretry.com/pages/a2f161/) -- [功能实例](https://www.easyretry.com/pages/960e25/) +- [这款分布式重试组件,治好了我的重试强迫症!](https://juejin.cn/post/7249607108043145274) +- [系统简介](https://www.easyretry.com/pages/d1d1da/) +- [架构与功能](https://www.easyretry.com/pages/540554/) + ## 原理 -- [客户端原理剖析](https://gitee.com/aizuda/easy-retry/tree/dev/example) -- [服务端原理剖析](https://gitee.com/aizuda/easy-retry/tree/dev/example) +- [场景应用](https://www.easyretry.com/pages/406a68/) +- [HelloWorld](https://www.easyretry.com/pages/da9ecc/) ## 应用实例 -- [Spring-Boot](https://gitee.com/aizuda/easy-retry/tree/dev/example) +- [easy-retry-demo](https://gitee.com/zhangyutongxue/easy-retry-demo) ## 期望 欢迎提出更好的意见,帮助完善 Easy-Retry diff --git a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/service/impl/RetryServiceImpl.java b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/service/impl/RetryServiceImpl.java index f3235f553..25126ba2c 100644 --- a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/service/impl/RetryServiceImpl.java +++ b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/service/impl/RetryServiceImpl.java @@ -232,6 +232,10 @@ public class RetryServiceImpl implements RetryService { waitDelDeadLetters.addAll(finishCallbackRetryIdList); } + if (CollectionUtils.isEmpty(waitDelDeadLetters)) { + return Boolean.TRUE; + } + RequestDataHelper.setPartition(groupName); Assert.isTrue(waitDelDeadLetters.size() == retryTaskMapper.deleteBatchIds(waitDelDeadLetters), () -> new EasyRetryServerException("删除重试数据失败 [{}]", JsonUtil.toJsonString(retryTasks))); diff --git a/pom.xml b/pom.xml index 7e4603fc6..1b4f141c8 100644 --- a/pom.xml +++ b/pom.xml @@ -21,7 +21,7 @@