Uses of Interface
org.springframework.data.redis.connection.ReactiveSubscription.Message

Packages that use ReactiveSubscription.Message

Package	Description
org.springframework.data.redis.connection	Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
org.springframework.data.redis.core	Core package for integrating Redis with Spring concepts.
org.springframework.data.redis.listener	Base package for Redis message listener / pubsub container facility

Uses of ReactiveSubscription.Message in org.springframework.data.redis.connection

Classes in org.springframework.data.redis.connection that implement ReactiveSubscription.Message

Modifier and Type	Class	Description
static class	ReactiveSubscription.ChannelMessage<C,M>	Value object for a Redis channel message.
static class	ReactiveSubscription.PatternMessage<P,C,M>	Value object for a Redis channel message received from a pattern subscription.

Methods in org.springframework.data.redis.connection that return types with arguments of type ReactiveSubscription.Message

Modifier and Type	Method	Description
reactor.core.publisher.Flux<ReactiveSubscription.Message<ByteBuffer,ByteBuffer>>	ReactiveSubscription.receive()	Retrieve the message stream emitting messages.

Uses of ReactiveSubscription.Message in org.springframework.data.redis.core

Methods in org.springframework.data.redis.core that return types with arguments of type ReactiveSubscription.Message

Modifier and Type	Method	Description
reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,V>>	ReactiveRedisOperations.listenTo(Topic... topics)	Subscribe to the Redis channels for the given topics and emit messages received for those.
reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,V>>	ReactiveRedisTemplate.listenTo(Topic... topics)
default reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,V>>	ReactiveRedisOperations.listenToChannel(String... channels)	Subscribe to the given Redis channels and emit messages received for those.
default reactor.core.publisher.Mono<reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,V>>>	ReactiveRedisOperations.listenToChannelLater(String... channels)	Subscribe to the given Redis channels and emit messages received for those.
reactor.core.publisher.Mono<reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,V>>>	ReactiveRedisOperations.listenToLater(Topic... topics)	Subscribe to the Redis channels for the given topics and emit messages received for those.
reactor.core.publisher.Mono<reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,V>>>	ReactiveRedisTemplate.listenToLater(Topic... topics)
default reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,V>>	ReactiveRedisOperations.listenToPattern(String... patterns)	Subscribe to the Redis channels matching the given pattern and emit messages received for those.
default reactor.core.publisher.Mono<reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,V>>>	ReactiveRedisOperations.listenToPatternLater(String... patterns)	Subscribe to the Redis channels matching the given pattern and emit messages received for those.

Uses of ReactiveSubscription.Message in org.springframework.data.redis.listener

Methods in org.springframework.data.redis.listener that return types with arguments of type ReactiveSubscription.Message

Modifier and Type	Method	Description
reactor.core.publisher.Flux<ReactiveSubscription.Message<String,String>>	ReactiveRedisMessageListenerContainer.receive(Iterable<? extends Topic> topics, SubscriptionListener subscriptionListener)	Subscribe to one or more Topics and receive a stream of ReactiveSubscription.ChannelMessage.
<C, B> reactor.core.publisher.Flux<ReactiveSubscription.Message<C,B>>	ReactiveRedisMessageListenerContainer.receive(Iterable<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer)	Subscribe to one or more Topics and receive a stream of ReactiveSubscription.ChannelMessage.
<C, B> reactor.core.publisher.Flux<ReactiveSubscription.Message<C,B>>	ReactiveRedisMessageListenerContainer.receive(Iterable<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer, SubscriptionListener subscriptionListener)	Subscribe to one or more Topics and receive a stream of ReactiveSubscription.ChannelMessage.
reactor.core.publisher.Flux<ReactiveSubscription.Message<String,String>>	ReactiveRedisMessageListenerContainer.receive(ChannelTopic... channelTopics)	Subscribe to one or more ChannelTopics and receive a stream of ReactiveSubscription.ChannelMessage.
<C, B> reactor.core.publisher.Mono<reactor.core.publisher.Flux<ReactiveSubscription.Message<C,B>>>	ReactiveRedisMessageListenerContainer.receiveLater(Iterable<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer)	Subscribe to one or more Topics and receive a stream of ReactiveSubscription.ChannelMessage.
reactor.core.publisher.Mono<reactor.core.publisher.Flux<ReactiveSubscription.Message<String,String>>>	ReactiveRedisMessageListenerContainer.receiveLater(ChannelTopic... channelTopics)	Subscribe to one or more ChannelTopics and receive a stream of ReactiveSubscription.ChannelMessage once the returned Mono completes.