Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polishing.

Browse Source 
Tweak wording.

See #3021
This commit is contained in:
Mark Paluch
2024-11-14 15:48:50 +01:00
parent e2746ecf5a
commit cb73f0b6ec
1 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/main/java/org/springframework/data/redis/stream/StreamMessageListenerContainer.java
View File

@@ -156,8 +156,8 @@ public interface StreamMessageListenerContainer<K, V extends Record<K, ?>> exten
}
/**
* 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 @@ public interface StreamMessageListenerContainer<K, V extends Record<K, ?>> exten
}
/**
* 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 @@ public interface StreamMessageListenerContainer<K, V extends Record<K, ?>> exten
}
/**
* 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 @@ public interface StreamMessageListenerContainer<K, V extends Record<K, ?>> exten
}
/**
* 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 @@ public interface StreamMessageListenerContainer<K, V extends Record<K, ?>> exten
/**
* 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}.
*/