Package io.lettuce.core.cluster.pubsub
Class RedisClusterPubSubAdapter<K,V>
- java.lang.Object
-
- io.lettuce.core.cluster.pubsub.RedisClusterPubSubAdapter<K,V>
-
- Type Parameters:
K
- Key type.V
- Value type.
- All Implemented Interfaces:
RedisClusterPubSubListener<K,V>
public class RedisClusterPubSubAdapter<K,V> extends Object implements RedisClusterPubSubListener<K,V>
Convenience adapter with an empty implementation of allRedisClusterPubSubListener
callback methods.- Since:
- 4.4
- Author:
- Mark Paluch
-
-
Constructor Summary
Constructors Constructor Description RedisClusterPubSubAdapter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
message(RedisClusterNode node, K pattern, K channel, V message)
Message received from a pattern subscription.void
message(RedisClusterNode node, K channel, V message)
Message received from a channel subscription.void
psubscribed(RedisClusterNode node, K pattern, long count)
Subscribed to a pattern.void
punsubscribed(RedisClusterNode node, K pattern, long count)
Unsubscribed from a pattern.void
subscribed(RedisClusterNode node, K channel, long count)
Subscribed to a channel.void
unsubscribed(RedisClusterNode node, K channel, long count)
Unsubscribed from a channel.
-
-
-
Method Detail
-
message
public void message(RedisClusterNode node, K channel, V message)
Description copied from interface:RedisClusterPubSubListener
Message received from a channel subscription.- Specified by:
message
in interfaceRedisClusterPubSubListener<K,V>
- Parameters:
node
- theRedisClusterNode
from which themessage
originates.channel
- Channel.message
- Message.
-
message
public void message(RedisClusterNode node, K pattern, K channel, V message)
Description copied from interface:RedisClusterPubSubListener
Message received from a pattern subscription.- Specified by:
message
in interfaceRedisClusterPubSubListener<K,V>
- Parameters:
node
- theRedisClusterNode
from which themessage
originates.pattern
- Patternchannel
- Channelmessage
- Message
-
subscribed
public void subscribed(RedisClusterNode node, K channel, long count)
Description copied from interface:RedisClusterPubSubListener
Subscribed to a channel.- Specified by:
subscribed
in interfaceRedisClusterPubSubListener<K,V>
- Parameters:
node
- theRedisClusterNode
from which themessage
originates.channel
- Channelcount
- Subscription count.
-
psubscribed
public void psubscribed(RedisClusterNode node, K pattern, long count)
Description copied from interface:RedisClusterPubSubListener
Subscribed to a pattern.- Specified by:
psubscribed
in interfaceRedisClusterPubSubListener<K,V>
- Parameters:
node
- theRedisClusterNode
from which themessage
originates.pattern
- Pattern.count
- Subscription count.
-
unsubscribed
public void unsubscribed(RedisClusterNode node, K channel, long count)
Description copied from interface:RedisClusterPubSubListener
Unsubscribed from a channel.- Specified by:
unsubscribed
in interfaceRedisClusterPubSubListener<K,V>
- Parameters:
node
- theRedisClusterNode
from which themessage
originates.channel
- Channelcount
- Subscription count.
-
punsubscribed
public void punsubscribed(RedisClusterNode node, K pattern, long count)
Description copied from interface:RedisClusterPubSubListener
Unsubscribed from a pattern.- Specified by:
punsubscribed
in interfaceRedisClusterPubSubListener<K,V>
- Parameters:
node
- theRedisClusterNode
from which themessage
originates.pattern
- Channelcount
- Subscription count.
-
-