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
|
Modifier and Type | Class and 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.
|
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<ReactiveSubscription.Message<ByteBuffer,ByteBuffer>> |
ReactiveSubscription.receive()
Retrieve the message stream emitting
messages . |
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) |
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.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. |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<ReactiveSubscription.Message<String,String>> |
ReactiveRedisMessageListenerContainer.receive(ChannelTopic... channelTopics)
Subscribe to one or more
ChannelTopic 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)
Subscribe to one or more
Topic s and receive a stream of ReactiveSubscription.ChannelMessage The stream may contain
ReactiveSubscription.PatternMessage if subscribed to patterns. |
Copyright © 2011–2018 Pivotal Software, Inc.. All rights reserved.