Uses of Interface
org.springframework.data.redis.connection.ReactiveSubscription.Message
Packages that use ReactiveSubscription.Message
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
Core package for integrating Redis with Spring concepts.
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.MessageModifier and TypeClassDescriptionstatic class
Value object for a Redis channel message.static class
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 -
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.MessageModifier and TypeMethodDescriptionFlux<? extends ReactiveSubscription.Message<String,
V>> Flux<? extends ReactiveSubscription.Message<String,
V>> default Flux<? extends ReactiveSubscription.Message<String,
V>> ReactiveRedisOperations.listenToChannel
(String... channels) Subscribe to the given Redischannels
and emitmessages
received for those.default Mono<Flux<? extends ReactiveSubscription.Message<String,
V>>> ReactiveRedisOperations.listenToChannelLater
(String... channels) Subscribe to the given Redischannels
and emitmessages
received for those.Mono<Flux<? extends ReactiveSubscription.Message<String,
V>>> ReactiveRedisOperations.listenToLater
(Topic... topics) Mono<Flux<? extends ReactiveSubscription.Message<String,
V>>> ReactiveRedisTemplate.listenToLater
(Topic... topics) default Flux<? extends ReactiveSubscription.Message<String,
V>> ReactiveRedisOperations.listenToPattern
(String... patterns) Subscribe to the Redis channels matching the givenpattern
and emitmessages
received for those.default Mono<Flux<? extends ReactiveSubscription.Message<String,
V>>> ReactiveRedisOperations.listenToPatternLater
(String... patterns) Subscribe to the Redis channels matching the givenpattern
and emitmessages
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.MessageModifier and TypeMethodDescriptionReactiveRedisMessageListenerContainer.receive
(Iterable<? extends Topic> topics, SubscriptionListener subscriptionListener) Subscribe to one or moreTopic
s and receive a stream ofReactiveSubscription.ChannelMessage
.<C,
B> Flux<ReactiveSubscription.Message<C, B>> ReactiveRedisMessageListenerContainer.receive
(Iterable<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer) Subscribe to one or moreTopic
s and receive a stream ofReactiveSubscription.ChannelMessage
.<C,
B> 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 moreTopic
s and receive a stream ofReactiveSubscription.ChannelMessage
.ReactiveRedisMessageListenerContainer.receive
(ChannelTopic... channelTopics) Subscribe to one or moreChannelTopic
s and receive a stream ofReactiveSubscription.ChannelMessage
.<C,
B> Mono<Flux<ReactiveSubscription.Message<C, B>>> ReactiveRedisMessageListenerContainer.receiveLater
(Iterable<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer) Subscribe to one or moreTopic
s and receive a stream ofReactiveSubscription.ChannelMessage
.ReactiveRedisMessageListenerContainer.receiveLater
(ChannelTopic... channelTopics) Subscribe to one or moreChannelTopic
s and receive a stream ofReactiveSubscription.ChannelMessage
once the returnedMono
completes.