diff --git a/src/main/java/org/springframework/data/redis/stream/StreamMessageListenerContainer.java b/src/main/java/org/springframework/data/redis/stream/StreamMessageListenerContainer.java index ff06716ac6..febe221623 100644 --- a/src/main/java/org/springframework/data/redis/stream/StreamMessageListenerContainer.java +++ b/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 Stream key and Stream field type. * @param Stream value type. * @since 2.2 @@ -155,9 +156,10 @@ static StreamMessageListenerContainer> } /** - * 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}. *

* Errors during {@link Record} retrieval lead to {@link Subscription#cancel() cancellation} of the underlying task. *

@@ -174,9 +176,10 @@ default Subscription receive(StreamOffset streamOffset, StreamListener } /** - * 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}. *

* 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 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}. *

* Every message is acknowledged when received. *

@@ -223,9 +227,10 @@ default Subscription receiveAutoAck(Consumer consumer, StreamOffset 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}. *

* Errors during {@link Record} are tested against test {@link StreamReadRequest#getCancelSubscriptionOnError() * cancellation predicate} whether to cancel the underlying task.