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 851a1f6d66..172ffc05ec 100644 --- a/src/main/java/org/springframework/data/redis/stream/StreamMessageListenerContainer.java +++ b/src/main/java/org/springframework/data/redis/stream/StreamMessageListenerContainer.java @@ -107,6 +107,8 @@ * @author Christoph Strobl * @author Christian Rest * @author DongCheol Kim + * @author Wilson Chuks + * * @param Stream key and Stream field type. * @param Stream value type. * @since 2.2 @@ -635,12 +637,12 @@ public StreamMessageListenerContainerOptionsBuilder pollTimeout(Duration p /** * Configure a batch size for the {@code COUNT} option during reading. * - * @param messagesPerPoll must not be greater zero. + * @param messagesPerPoll must be greater than zero. * @return {@code this} {@link StreamMessageListenerContainerOptionsBuilder}. */ public StreamMessageListenerContainerOptionsBuilder batchSize(int messagesPerPoll) { - Assert.isTrue(messagesPerPoll > 0, "Batch size must be greater zero"); + Assert.isTrue(messagesPerPoll > 0, "Batch size must be greater than zero"); this.batchSize = messagesPerPoll; return this;