修复 Redis Pub/Sub 广播消费的容器默认未启动的问题

默认配置没有启动Redis Pub/Sub 广播消费的容器导致发出消息后消费者收不到消息 Signed-off-by: 筱龙缘 <794334212@qq.com>
2023-02-17 09:58:38 +00:00 · 2023-02-17 09:58:38 +00:00 · edc52d5f4f
parent 063d5e3a8a
commit edc52d5f4f
1 changed files with 1 additions and 1 deletions
--- 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<AbstractChannelMessageListener<?>> listeners) {
        // 创建 RedisMessageListenerContainer 对象