From edc52d5f4f80333368997d80e2fcbd34dea59dd7 Mon Sep 17 00:00:00 2001 From: 筱龙缘 <794334212@qq.com> Date: Fri, 17 Feb 2023 09:58:38 +0000 Subject: [PATCH] 修复 Redis Pub/Sub 广播消费的容器 默认未启动的问题 默认配置没有启动Redis Pub/Sub 广播消费的容器 导致发出消息后 消费者收不到消息 --- yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/config/YudaoMQAutoConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/config/YudaoMQAutoConfiguration.java b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/config/YudaoMQAutoConfiguration.java index 042a4f7..b452aa5 100644 --- a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/config/YudaoMQAutoConfiguration.java +++ b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/config/YudaoMQAutoConfiguration.java @@ -56,7 +56,7 @@ public class YudaoMQAutoConfiguration { /** * 创建 Redis Pub/Sub 广播消费的容器 */ - @Bean + @Bean(initMethod = "start", destroyMethod = "stop") public RedisMessageListenerContainer redisMessageListenerContainer( RedisMQTemplate redisMQTemplate, List> listeners) { // 创建 RedisMessageListenerContainer 对象 -- libgit2 0.21.4