Polishing.

Tweak wording.

See #3021

Author: mp911de

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

@@ -156,8 +156,8 @@ static StreamMessageListenerContainer<String, MapRecord<String, String, String>>
 	}
 
 	/**
-	 * 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
+	 * Register a new subscription for a Redis Stream. If the container is already
+	 * {@link StreamMessageListenerContainer#isRunning() running} the {@link Subscription} will be added and started
 	 * immediately, otherwise it'll be scheduled and started once the container is actually
 	 * {@link StreamMessageListenerContainer#start() started}.
 	 * <p>
@@ -176,8 +176,8 @@ default Subscription receive(StreamOffset<K> streamOffset, StreamListener<K, V>
 	}
 
 	/**
-	 * 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
+	 * Register a new subscription for a Redis Stream. If the container is already
+	 * {@link StreamMessageListenerContainer#isRunning() running} the {@link Subscription} will be added and started
 	 * immediately, otherwise it'll be scheduled and started once the container is actually
 	 * {@link StreamMessageListenerContainer#start() started}.
 	 * <p>
@@ -203,8 +203,8 @@ default Subscription receive(Consumer consumer, StreamOffset<K> streamOffset, St
 	}
 
 	/**
-	 * 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
+	 * Register a new subscription for a Redis Stream. If the container is already
+	 * {@link StreamMessageListenerContainer#isRunning() running} the {@link Subscription} will be added and started
 	 * immediately, otherwise it'll be scheduled and started once the container is actually
 	 * {@link StreamMessageListenerContainer#start() started}.
 	 * <p>
@@ -227,8 +227,8 @@ default Subscription receiveAutoAck(Consumer consumer, StreamOffset<K> streamOff
 	}
 
 	/**
-	 * 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
+	 * Register a new subscription for a Redis Stream. If the container is already
+	 * {@link StreamMessageListenerContainer#isRunning() running} the {@link Subscription} will be added and started
 	 * immediately, otherwise it'll be scheduled and started once the container is actually
 	 * {@link StreamMessageListenerContainer#start() started}.
 	 * <p>
@@ -250,9 +250,9 @@ default Subscription receiveAutoAck(Consumer consumer, StreamOffset<K> streamOff
 
 	/**
 	 * Unregister a given {@link Subscription} from the container. This prevents the {@link Subscription} to be restarted
-	 * in a potential {@link SmartLifecycle#stop() stop}/{@link SmartLifecycle#start() start} scenario.<br />
-	 * An {@link Subscription#isActive() active} {@link Subscription subcription} is {@link Subscription#cancel()
-	 * cancelled} prior to removal.
+	 * in a potential {@link SmartLifecycle#stop() stop}/{@link SmartLifecycle#start() start} scenario. An
+	 * {@link Subscription#isActive() active} {@link Subscription subcription} is {@link Subscription#cancel() cancelled}
+	 * prior to removal.
 	 *
 	 * @param subscription must not be {@literal null}.
 	 */