lxd/FlowPacs
2
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

fix: 解决 redis mq 消息丢失问题

Browse Source
This commit is contained in:
gaibu 2022-12-23 10:32:18 +08:00
parent e9645d7054
commit 2d7d3f1511
1 changed files with 0 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/scheduler/RedisPendingMessageResendJob.java
View File

@ -43,7 +43,6 @@ public class RedisPendingMessageResendJob {
@Scheduled(cron = "35 * * * * ?") @Scheduled(cron = "35 * * * * ?")
public void messageResend() { public void messageResend() {
RLock lock = redissonClient.getLock(LOCK_KEY); RLock lock = redissonClient.getLock(LOCK_KEY);
log.info("[messageResend][尝试获取锁]");
// 尝试加锁 // 尝试加锁
if (lock.tryLock()) { if (lock.tryLock()) {
try { try {