Polishing.

Tweak wording. See #3021
spring-projects · Nov 14, 2024 · a079f9e · a079f9e
1 parent 9611063
commit a079f9e
Showing 1 changed file with 11 additions and 11 deletions.
diff --git a/src/main/java/org/springframework/data/redis/stream/StreamMessageListenerContainer.java b/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}.
 	 */