🎨 添加消息管道需要的默认RedisMessageListenerContainer

Author: hengboy

api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/server/MessagePipeServerAutoConfiguration.java

@@ -7,6 +7,8 @@
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.listener.RedisMessageListenerContainer;
 
 import java.util.List;
 import java.util.stream.Collectors;
@@ -36,6 +38,22 @@ public ServerConfiguration serverConfiguration() {
         return messagePipeServerProperties.getConfiguration();
     }
 
+    /**
+     * Instantiate {@link RedisMessageListenerContainer}
+     * <p>
+     * This instance is required by the message pipeline, but here is just the default configuration
+     *
+     * @param redisConnectionFactory The {@link RedisConnectionFactory} redis connectory factory instance
+     * @return The {@link RedisMessageListenerContainer} instance
+     */
+    @Bean
+    @ConditionalOnMissingBean
+    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory redisConnectionFactory) {
+        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
+        container.setConnectionFactory(redisConnectionFactory);
+        return container;
+    }
+
     /**
      * Instantiate the wrapper class of {@link MessagePipeConfigurationCustomizer}
      *