Package | Description |
---|---|
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
|
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,V>> |
ReactiveRedisOperations.listenTo(Topic... topics)
|
reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<String,V>> |
ReactiveRedisTemplate.listenTo(Topic... topics) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
ChannelTopic
Channel topic implementation (maps to a Redis channel).
|
class |
PatternTopic
Pattern topic (matching multiple channels).
|
Modifier and Type | Method and Description |
---|---|
void |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
RedisMessageListenerContainer.addMessageListener(MessageListener listener,
Collection<? extends Topic> topics)
Adds a message listener to the (potentially running) container.
|
<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
Topic s 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
Topic s and receive a stream of ReactiveSubscription.ChannelMessage . |
reactor.core.publisher.Flux<ReactiveSubscription.Message<String,String>> |
ReactiveRedisMessageListenerContainer.receive(Iterable<? extends Topic> topics,
SubscriptionListener subscriptionListener)
Subscribe to one or more
Topic s 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
Topic s and receive a stream of ReactiveSubscription.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.
|
Copyright © 2011–2023 Pivotal Software, Inc.. All rights reserved.