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.connection.jedis |
Connection package for Jedis library.
|
org.springframework.data.redis.connection.lettuce |
Connection package for Lettuce Redis client.
|
org.springframework.data.redis.connection.util |
Internal utility package for encoding/decoding Strings to byte[] (using Base64) library.
|
org.springframework.data.redis.listener |
Base package for Redis message listener / pubsub container facility
|
org.springframework.data.redis.listener.adapter |
Message listener adapter package.
|
Modifier and Type | Method and Description |
---|---|
MessageListener |
Subscription.getListener()
Returns the listener used for this subscription.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultStringRedisConnection.pSubscribe(MessageListener listener,
byte[]... patterns) |
void |
RedisPubSubCommands.pSubscribe(MessageListener listener,
byte[]... patterns)
Subscribes the connection to all channels matching the given patterns.
|
void |
DefaultStringRedisConnection.pSubscribe(MessageListener listener,
String... patterns) |
void |
StringRedisConnection.pSubscribe(MessageListener listener,
String... patterns)
Subscribes the connection to all channels matching the given patterns.
|
void |
DefaultStringRedisConnection.subscribe(MessageListener listener,
byte[]... channels) |
void |
RedisPubSubCommands.subscribe(MessageListener listener,
byte[]... channels)
Subscribes the connection to the given channels.
|
void |
DefaultStringRedisConnection.subscribe(MessageListener listener,
String... channels) |
void |
StringRedisConnection.subscribe(MessageListener listener,
String... channels)
Subscribes the connection to the given channels.
|
Modifier and Type | Method and Description |
---|---|
void |
JedisConnection.pSubscribe(MessageListener listener,
byte[]... patterns) |
void |
JedisClusterConnection.pSubscribe(MessageListener listener,
byte[]... patterns) |
void |
JedisConnection.subscribe(MessageListener listener,
byte[]... channels) |
void |
JedisClusterConnection.subscribe(MessageListener listener,
byte[]... channels) |
Modifier and Type | Method and Description |
---|---|
protected LettuceSubscription |
LettuceConnection.doCreateSubscription(MessageListener listener,
io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[],byte[]> connection,
LettuceConnectionProvider connectionProvider)
Customization hook to create a
LettuceSubscription . |
void |
LettuceConnection.pSubscribe(MessageListener listener,
byte[]... patterns) |
void |
LettuceConnection.subscribe(MessageListener listener,
byte[]... channels) |
Constructor and Description |
---|
LettuceSubscription(MessageListener listener,
io.lettuce.core.pubsub.StatefulRedisPubSubConnection<byte[],byte[]> pubsubConnection,
LettuceConnectionProvider connectionProvider)
Creates a new
LettuceSubscription given MessageListener , StatefulRedisPubSubConnection , and
LettuceConnectionProvider . |
Modifier and Type | Method and Description |
---|---|
MessageListener |
AbstractSubscription.getListener() |
Constructor and Description |
---|
AbstractSubscription(MessageListener listener) |
AbstractSubscription(MessageListener listener,
byte[][] channels,
byte[][] patterns)
Constructs a new
AbstractSubscription instance. |
Modifier and Type | Class and Description |
---|---|
class |
KeyExpirationEventMessageListener
MessageListener publishing RedisKeyExpiredEvent s via ApplicationEventPublisher by listening
to Redis keyspace notifications for key expirations. |
class |
KeyspaceEventMessageListener
Base
MessageListener implementation for listening to Redis keyspace notifications. |
Modifier and Type | Method and Description |
---|---|
void |
RedisMessageListenerContainer.addMessageListener(MessageListener listener,
Collection<? extends Topic> topics)
Adds a message listener to the (potentially running) container.
|
void |
RedisMessageListenerContainer.addMessageListener(MessageListener listener,
Topic topic)
Adds a message listener to the (potentially running) container.
|
protected void |
RedisMessageListenerContainer.executeListener(MessageListener listener,
Message message,
byte[] pattern)
Execute the specified listener.
|
protected void |
RedisMessageListenerContainer.processMessage(MessageListener listener,
Message message,
byte[] pattern)
Process a message received from the provider.
|
void |
RedisMessageListenerContainer.removeMessageListener(MessageListener listener)
Removes the given message listener completely (from all topics).
|
void |
RedisMessageListenerContainer.removeMessageListener(MessageListener listener,
Collection<? extends Topic> topics)
Removes a message listener from the given topics.
|
void |
RedisMessageListenerContainer.removeMessageListener(MessageListener listener,
Topic topic)
Removes a message listener from the from the given topic.
|
Modifier and Type | Method and Description |
---|---|
void |
RedisMessageListenerContainer.setMessageListeners(Map<? extends MessageListener,Collection<? extends Topic>> listeners)
Attaches the given listeners (and their topics) to the container.
|
Modifier and Type | Class and Description |
---|---|
class |
MessageListenerAdapter
Message listener adapter that delegates the handling of messages to target listener methods via reflection, with
flexible message type conversion.
|
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.