moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

账单-mq-定时任务-限制单次重试数量

Browse Source
This commit is contained in:
khalil
2025-05-22 16:00:03 +08:00
parent 1f4e3dfd54
commit 06e791fbfc
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/BillTask.java
View File

@@ -24,7 +24,7 @@ public class BillTask extends BaseTask {
@Scheduled(cron = "0 */5 * * * ?")
public void retryBillQueue() {
log.info("retryBillQueue start ...");
Map<String, BillMessage> map = billMessageService.getRecordMessMap().readAllMap();
Map<String, BillMessage> map = billMessageService.getRecordMessMap().randomEntries(20000);
if (CollectionUtils.isEmpty(map)) {
return;
}

2
accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/luckyBag/BravoTask.java
View File

@@ -46,7 +46,7 @@ public class BravoTask {
@Scheduled(cron = "0 */5 * * * ?")
public void retryBravoQueue() {
log.info("retryBravoQueue start ...");
Map<String, String> map = jedisService.hgetAll(RedisKey.lucky_24_status.getKey());
Map<String, String> map = jedisService.hgetAll(RedisKey.bravo_status.getKey());
if (map == null || map.isEmpty()) {
return;
}