@@ -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<Message<String, String>> 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<Flux<Message<String, String>>> receiveLater(ChannelTopic... channelTopics) {
|
||||
|
||||
Reference in New Issue
Block a user