[GH-3208] Feat: Allow configuring 'autoStartup' in RedisMessageListenerContainer

Signed-off-by: Su Ko <[email protected]>

Author: bandalgomsu

src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java

@@ -170,6 +170,7 @@ public class RedisMessageListenerContainer implements InitializingBean, Disposab
 	private @Nullable Subscriber subscriber;
 
     private int phase = Integer.MAX_VALUE;
+    private boolean autoStartup = true;
 
 	/**
 	 * Set an ErrorHandler to be invoked in case of any uncaught exceptions thrown while processing a Message. By default,
@@ -637,6 +638,22 @@ public void setPhase(int phase) {
         this.phase = phase;
     }
 
+    @Override
+    public boolean isAutoStartup() {
+        return this.autoStartup;
+    }
+
+    /**
+     * Configure if this Lifecycle connection factory should get started automatically by the container at the time that
+     * the containing ApplicationContext gets refreshed.
+     * The default is {@code true}.
+     *
+     * @see SmartLifecycle#isAutoStartup()
+     */
+    public void setAutoStartup(boolean autoStartup) {
+        this.autoStartup = autoStartup;
+    }
+
 	private void initMapping(Map<? extends MessageListener, Collection<? extends Topic>> listeners) {
 
 		// stop the listener if currently running

src/test/java/org/springframework/data/redis/listener/RedisMessageListenerContainerUnitTests.java

@@ -250,4 +250,16 @@ void shouldApplyConfiguredPhase() {
         container.setPhase(3208);
         assertThat(container.getPhase()).isEqualTo(3208);
     }
+
+    @Test // GH-3208
+    void defaultAutoStartupShouldBeMaxValue() {
+        assertThat(container.isAutoStartup()).isEqualTo(true);
+    }
+
+    @Test // GH-3208
+    void shouldApplyConfiguredAutoStartup() {
+        container.setAutoStartup(false);
+        assertThat(container.isAutoStartup()).isEqualTo(false);
+    }
+
 }