Polishing.

- Remove comments from docs (details can be found in the javadocs and reduces maintenance
- Remove Lettuce specific ITs added in previous commit (already covered in base test)
- Added Javadoc to setAutoStartup

Original Pull Request #3293

Signed-off-by: Chris Bono <chris.bono@broadcom.com>

Author: onobc

src/main/antora/modules/ROOT/pages/redis/redis-streams.adoc

@@ -128,8 +128,6 @@ StreamMessageListenerContainer<String, MapRecord<String, String, String>> contai
 Subscription subscription = container.receive(StreamOffset.fromStart("my-stream"), streamListener);
 ----
 
-The default value for `autoStartup` is `true`.
-
 Please refer to the Javadoc of the various message listener containers for a full description of the features supported by each implementation.
 
 [[reactive-streamreceiver]]

src/main/java/org/springframework/data/redis/stream/DefaultStreamMessageListenerContainer.java

@@ -51,6 +51,7 @@
  * @author Mark Paluch
  * @author Christoph Strobl
  * @author Su Ko
+ * @author Yumin Jung
  * @since 2.2
  */
 class DefaultStreamMessageListenerContainer<K, V extends Record<K, ?>> implements StreamMessageListenerContainer<K, V> {
@@ -192,6 +193,13 @@ public boolean isAutoStartup() {
 		return this.autoStartup;
 	}
 
+	/**
+	 * Configure if this listener container should get started automatically at the time that the containing
+	 * {@code ApplicationContext} gets refreshed. The default is {@code true}.
+	 *
+	 * @see org.springframework.context.SmartLifecycle#isAutoStartup()
+	 * @since 4.1
+	 */
 	public void setAutoStartup(boolean autoStartup) {
 		this.autoStartup = autoStartup;
 	}

src/test/java/org/springframework/data/redis/stream/AbstractStreamMessageListenerContainerIntegrationTests.java

@@ -386,6 +386,7 @@ void containerRestartShouldRestartSubscription() throws InterruptedException {
 
 	@Test // GH-3208
 	void defaultPhaseShouldBeMaxValue() {
+
 		StreamMessageListenerContainer<String, MapRecord<String, String, String>> container = StreamMessageListenerContainer
 				.create(connectionFactory, containerOptions);
 
@@ -394,6 +395,7 @@ void defaultPhaseShouldBeMaxValue() {
 
 	@Test // GH-3208
 	void shouldApplyConfiguredPhase() {
+
 		StreamMessageListenerContainerOptions<String, MapRecord<String, String, String>> options = StreamMessageListenerContainerOptions
 				.builder().phase(3208).build();
 		StreamMessageListenerContainer<String, MapRecord<String, String, String>> container = StreamMessageListenerContainer
@@ -413,6 +415,7 @@ void defaultAutoStartupShouldBeTrue() {
 
 	@Test // GH-3208
 	void shouldApplyConfiguredAutoStartup() {
+
 		StreamMessageListenerContainerOptions<String, MapRecord<String, String, String>> options = StreamMessageListenerContainerOptions
 				.builder().autoStartup(true).build();
 		StreamMessageListenerContainer<String, MapRecord<String, String, String>> container = StreamMessageListenerContainer
@@ -421,6 +424,17 @@ void shouldApplyConfiguredAutoStartup() {
 		assertThat(container.isAutoStartup()).isEqualTo(true);
 	}
 
+	@Test // GH-2568
+	void shouldRetainAutoStartupSetting() {
+
+		DefaultStreamMessageListenerContainer container = new DefaultStreamMessageListenerContainer(connectionFactory,
+				StreamMessageListenerContainerOptions.builder().autoStartup(false).build());
+
+		assertThat(container.isAutoStartup()).isFalse();
+		container.setAutoStartup(true);
+		assertThat(container.isAutoStartup()).isTrue();
+	}
+
 	private static void cancelAwait(Subscription subscription) {
 
 		subscription.cancel();

src/test/java/org/springframework/data/redis/stream/LettuceStreamMessageListenerContainerIntegrationTests.java

@@ -15,15 +15,11 @@
  */
 package org.springframework.data.redis.stream;
 
-import static org.assertj.core.api.Assertions.assertThat;
-
-import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInstance;
 import org.junit.jupiter.api.extension.ExtendWith;
 
 import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.connection.lettuce.extension.LettuceConnectionFactoryExtension;
-import org.springframework.data.redis.connection.stream.MapRecord;
 import org.springframework.data.redis.test.condition.EnabledOnCommand;
 
 /**
@@ -38,38 +34,8 @@
 public class LettuceStreamMessageListenerContainerIntegrationTests
 		extends AbstractStreamMessageListenerContainerIntegrationTests {
 
-	private final RedisConnectionFactory connectionFactory;
-
 	public LettuceStreamMessageListenerContainerIntegrationTests(RedisConnectionFactory connectionFactory) {
 		super(connectionFactory);
-		this.connectionFactory = connectionFactory;
-	}
-
-	@Test // GH-2568
-	void shouldHaveAutoStartupEnabledByDefault() {
-
-		StreamMessageListenerContainer.StreamMessageListenerContainerOptions<String, MapRecord<String, String, String>> options =
-				StreamMessageListenerContainer.StreamMessageListenerContainerOptions.builder().build();
-
-		StreamMessageListenerContainer<String, MapRecord<String, String, String>> container =
-				StreamMessageListenerContainer.create(connectionFactory, options);
-
-		assertThat(container.isAutoStartup()).isTrue();
 	}
 
-	@Test // GH-2568
-	void shouldAllowConfiguringAutoStartup() {
-
-		StreamMessageListenerContainer.StreamMessageListenerContainerOptions<String, MapRecord<String, String, String>> options =
-				StreamMessageListenerContainer.StreamMessageListenerContainerOptions.builder().build();
-
-		DefaultStreamMessageListenerContainer<String, MapRecord<String, String, String>> container =
-				new DefaultStreamMessageListenerContainer<>(connectionFactory, options);
-
-		container.setAutoStartup(false);
-		assertThat(container.isAutoStartup()).isFalse();
-
-		container.setAutoStartup(true);
-		assertThat(container.isAutoStartup()).isTrue();
-	}
 }