Commit 9b667448ea229f9c30a8fcc8c4b3ecf7a88f609d
1 parent
969b9c34
fix: 加入异步注解配置后redis消费者不能正常消费
Showing
1 changed file
with
0 additions
and
1 deletions
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/config/YudaoMQAutoConfiguration.java
| @@ -78,7 +78,6 @@ public class YudaoMQAutoConfiguration { | @@ -78,7 +78,6 @@ public class YudaoMQAutoConfiguration { | ||
| 78 | * Redis Stream 的 xreadgroup 命令：https://www.geek-book.com/src/docs/redis/redis/redis.io/commands/xreadgroup.html | 78 | * Redis Stream 的 xreadgroup 命令：https://www.geek-book.com/src/docs/redis/redis/redis.io/commands/xreadgroup.html |
| 79 | */ | 79 | */ |
| 80 | @Bean(initMethod = "start", destroyMethod = "stop") | 80 | @Bean(initMethod = "start", destroyMethod = "stop") |
| 81 | - @Async // 异步化，可降低 5 秒左右的启动时间 | ||
| 82 | public StreamMessageListenerContainer<String, ObjectRecord<String, String>> redisStreamMessageListenerContainer( | 81 | public StreamMessageListenerContainer<String, ObjectRecord<String, String>> redisStreamMessageListenerContainer( |
| 83 | RedisMQTemplate redisMQTemplate, List<AbstractStreamMessageListener<?>> listeners) { | 82 | RedisMQTemplate redisMQTemplate, List<AbstractStreamMessageListener<?>> listeners) { |
| 84 | RedisTemplate<String, ?> redisTemplate = redisMQTemplate.getRedisTemplate(); | 83 | RedisTemplate<String, ?> redisTemplate = redisMQTemplate.getRedisTemplate(); |