Uses of Interface
org.springframework.data.redis.listener.Topic
Packages that use Topic
Package
Description
Core package for integrating Redis with Spring concepts.
Base package for Redis message listener / pubsub container facility
-
Uses of Topic in org.springframework.data.redis.core
Methods in org.springframework.data.redis.core with parameters of type TopicModifier and TypeMethodDescriptionreactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,
V>> reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,
V>> reactor.core.publisher.Mono<reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,
V>>> ReactiveRedisOperations.listenToLater
(Topic... topics) reactor.core.publisher.Mono<reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,
V>>> ReactiveRedisTemplate.listenToLater
(Topic... topics) -
Uses of Topic in org.springframework.data.redis.listener
Classes in org.springframework.data.redis.listener that implement TopicModifier and TypeClassDescriptionclass
Channel Topic
implementation mapping to a Redis channel.class
Methods in org.springframework.data.redis.listener with parameters of type TopicModifier and TypeMethodDescriptionvoid
RedisMessageListenerContainer.addMessageListener
(MessageListener listener, Topic topic) Adds a message listener to the (potentially running) container.void
RedisMessageListenerContainer.removeMessageListener
(MessageListener listener, Topic topic) Removes a message listener from the given topic.Method parameters in org.springframework.data.redis.listener with type arguments of type TopicModifier and TypeMethodDescriptionvoid
RedisMessageListenerContainer.addMessageListener
(MessageListener listener, Collection<? extends Topic> topics) Adds a message listener to the (potentially running) container.reactor.core.publisher.Flux<ReactiveSubscription.Message<String,
String>> ReactiveRedisMessageListenerContainer.receive
(Iterable<? extends Topic> topics, SubscriptionListener subscriptionListener) Subscribe to one or moreTopic
s and receive a stream ofReactiveSubscription.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 moreTopic
s and receive a stream ofReactiveSubscription.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 moreTopic
s and receive a stream ofReactiveSubscription.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 moreTopic
s and receive a stream ofReactiveSubscription.ChannelMessage
.void
RedisMessageListenerContainer.removeMessageListener
(MessageListener listener, Collection<? extends Topic> topics) Removes a message listener from the given topics.void
RedisMessageListenerContainer.setMessageListeners
(Map<? extends MessageListener, Collection<? extends Topic>> listeners) Attaches the given listeners (and their topics) to the container.