Commit 0e6b4e463f4e49edea6642c15af7ba87099f2ebc
1 parent
2d7d3f15
fix: 解决 redis mq 消息丢失问题
Showing
2 changed files
with
2 additions
and
2 deletions
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/config/YudaoMQAutoConfiguration.java
| @@ -8,7 +8,7 @@ import cn.iocoder.yudao.framework.mq.core.RedisMQTemplate; | @@ -8,7 +8,7 @@ import cn.iocoder.yudao.framework.mq.core.RedisMQTemplate; | ||
| 8 | import cn.iocoder.yudao.framework.mq.core.interceptor.RedisMessageInterceptor; | 8 | import cn.iocoder.yudao.framework.mq.core.interceptor.RedisMessageInterceptor; |
| 9 | import cn.iocoder.yudao.framework.mq.core.pubsub.AbstractChannelMessageListener; | 9 | import cn.iocoder.yudao.framework.mq.core.pubsub.AbstractChannelMessageListener; |
| 10 | import cn.iocoder.yudao.framework.mq.core.stream.AbstractStreamMessageListener; | 10 | import cn.iocoder.yudao.framework.mq.core.stream.AbstractStreamMessageListener; |
| 11 | -import cn.iocoder.yudao.framework.mq.scheduler.RedisPendingMessageResendJob; | 11 | +import cn.iocoder.yudao.framework.mq.job.RedisPendingMessageResendJob; |
| 12 | import cn.iocoder.yudao.framework.redis.config.YudaoRedisAutoConfiguration; | 12 | import cn.iocoder.yudao.framework.redis.config.YudaoRedisAutoConfiguration; |
| 13 | import lombok.extern.slf4j.Slf4j; | 13 | import lombok.extern.slf4j.Slf4j; |
| 14 | import org.redisson.api.RedissonClient; | 14 | import org.redisson.api.RedissonClient; |
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/scheduler/RedisPendingMessageResendJob.java renamed to yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/job/RedisPendingMessageResendJob.java
| 1 | -package cn.iocoder.yudao.framework.mq.scheduler; | 1 | +package cn.iocoder.yudao.framework.mq.job; |
| 2 | 2 | ||
| 3 | import cn.hutool.core.collection.CollUtil; | 3 | import cn.hutool.core.collection.CollUtil; |
| 4 | import cn.iocoder.yudao.framework.mq.core.RedisMQTemplate; | 4 | import cn.iocoder.yudao.framework.mq.core.RedisMQTemplate; |