diff --git a/src/main/java/org/springframework/data/redis/listener/ReactiveRedisMessageListenerContainer.java b/src/main/java/org/springframework/data/redis/listener/ReactiveRedisMessageListenerContainer.java index 7a1e8affb..291eb8acf 100644 --- a/src/main/java/org/springframework/data/redis/listener/ReactiveRedisMessageListenerContainer.java +++ b/src/main/java/org/springframework/data/redis/listener/ReactiveRedisMessageListenerContainer.java @@ -146,7 +146,7 @@ public class ReactiveRedisMessageListenerContainer implements DisposableBean { * * @param channelTopics the channels to subscribe. * @return the message stream. - * @throws InvalidDataAccessApiUsageException if {@code patternTopics} is empty. + * @throws InvalidDataAccessApiUsageException if {@code channelTopics} is empty. * @see #receive(Iterable, SerializationPair, SerializationPair) */ public Flux> receive(ChannelTopic... channelTopics) { @@ -168,7 +168,7 @@ public class ReactiveRedisMessageListenerContainer implements DisposableBean { * * @param channelTopics the channels to subscribe. * @return the message stream. - * @throws InvalidDataAccessApiUsageException if {@code patternTopics} is empty. + * @throws InvalidDataAccessApiUsageException if {@code channelTopics} is empty. * @since 2.6 */ public Mono>> receiveLater(ChannelTopic... channelTopics) {