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.listener |
Base package for Redis message listener / pubsub container facility
|
Modifier and Type | Field and Description |
---|---|
static SubscriptionListener |
SubscriptionListener.NO_OP_SUBSCRIPTION_LISTENER
Empty
SubscriptionListener . |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<ReactiveSubscription> |
ReactivePubSubCommands.createSubscription(SubscriptionListener subscriptionListener)
Creates a subscription for this connection.
|
Modifier and Type | Method and Description |
---|---|
<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 . |
Copyright © 2011–2022 Pivotal Software, Inc.. All rights reserved.