Improve StreamMessageListenerContainer Javadoc.

Fix minor typos and improve the clarity of the StreamMessageListenerContainer Javadoc regarding subscription registration.

Closes #3021

Author: csct3434

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

@@ -106,6 +106,7 @@
  * @author Mark Paluch
  * @author Christoph Strobl
  * @author Christian Rest
+ * @author DongCheol Kim
  * @param <K> Stream key and Stream field type.
  * @param <V> Stream value type.
  * @since 2.2
@@ -155,9 +156,10 @@ static StreamMessageListenerContainer<String, MapRecord<String, String, String>>
 	}
 
 	/**
-	 * Register a new subscription for a Redis Stream. If the {@link StreamMessageListenerContainer#isRunning() is already
-	 * running} the {@link Subscription} will be added and run immediately, otherwise it'll be scheduled and started once
-	 * the container is actually {@link StreamMessageListenerContainer#start() started}.
+	 * Register a new subscription for a Redis Stream. If a {@link StreamMessageListenerContainer} is already
+	 * {@link StreamMessageListenerContainer#isRunning() running} the {@link Subscription} will be added and run
+	 * immediately, otherwise it'll be scheduled and started once the container is actually
+	 * {@link StreamMessageListenerContainer#start() started}.
 	 * <p>
 	 * Errors during {@link Record} retrieval lead to {@link Subscription#cancel() cancellation} of the underlying task.
 	 * <p>
@@ -174,9 +176,10 @@ default Subscription receive(StreamOffset<K> streamOffset, StreamListener<K, V>
 	}
 
 	/**
-	 * Register a new subscription for a Redis Stream. If the {@link StreamMessageListenerContainer#isRunning() is already
-	 * running} the {@link Subscription} will be added and run immediately, otherwise it'll be scheduled and started once
-	 * the container is actually {@link StreamMessageListenerContainer#start() started}.
+	 * Register a new subscription for a Redis Stream. If a {@link StreamMessageListenerContainer} is already
+	 * {@link StreamMessageListenerContainer#isRunning() running} the {@link Subscription} will be added and run
+	 * immediately, otherwise it'll be scheduled and started once the container is actually
+	 * {@link StreamMessageListenerContainer#start() started}.
 	 * <p>
 	 * Every message must be acknowledged using
 	 * {@link org.springframework.data.redis.core.StreamOperations#acknowledge(Object, String, String...)} after
@@ -200,9 +203,10 @@ default Subscription receive(Consumer consumer, StreamOffset<K> streamOffset, St
 	}
 
 	/**
-	 * Register a new subscription for a Redis Stream. If the {@link StreamMessageListenerContainer#isRunning() is already
-	 * running} the {@link Subscription} will be added and run immediately, otherwise it'll be scheduled and started once
-	 * the container is actually {@link StreamMessageListenerContainer#start() started}.
+	 * Register a new subscription for a Redis Stream. If a {@link StreamMessageListenerContainer} is already
+	 * {@link StreamMessageListenerContainer#isRunning() running} the {@link Subscription} will be added and run
+	 * immediately, otherwise it'll be scheduled and started once the container is actually
+	 * {@link StreamMessageListenerContainer#start() started}.
 	 * <p>
 	 * Every message is acknowledged when received.
 	 * <p>
@@ -223,9 +227,10 @@ default Subscription receiveAutoAck(Consumer consumer, StreamOffset<K> streamOff
 	}
 
 	/**
-	 * Register a new subscription for a Redis Stream. If the {@link StreamMessageListenerContainer#isRunning() is already
-	 * running} the {@link Subscription} will be added and run immediately, otherwise it'll be scheduled and started once
-	 * the container is actually {@link StreamMessageListenerContainer#start() started}.
+	 * Register a new subscription for a Redis Stream. If a {@link StreamMessageListenerContainer} is already
+	 * {@link StreamMessageListenerContainer#isRunning() running} the {@link Subscription} will be added and run
+	 * immediately, otherwise it'll be scheduled and started once the container is actually
+	 * {@link StreamMessageListenerContainer#start() started}.
 	 * <p>
 	 * Errors during {@link Record} are tested against test {@link StreamReadRequest#getCancelSubscriptionOnError()
 	 * cancellation predicate} whether to cancel the underlying task.