Package com.helix.core.cache.l4

Class CacheInvalidationSubscriber

java.lang.Object

redis.clients.jedis.JedisPubSubBase<String>

redis.clients.jedis.JedisPubSub

com.helix.core.cache.l4.CacheInvalidationSubscriber

public class CacheInvalidationSubscriber
extends redis.clients.jedis.JedisPubSub

Redis Pub/Sub subscriber listening on cluster invalidation channels.

Constructor Summary

Constructors

Constructor	Description
CacheInvalidationSubscriber(Consumer<String> onInvalidate)

Method Summary

Modifier and Type	Method	Description
boolean	awaitSubscribed(long timeout, TimeUnit unit)
void	onMessage(String channel, String message)
void	onSubscribe(String channel, int subscribedChannels)

Methods inherited from class redis.clients.jedis.JedisPubSub

encode

Methods inherited from class redis.clients.jedis.JedisPubSubBase

getSubscribedChannels, isSubscribed, onPMessage, onPong, onPSubscribe, onPUnsubscribe, onUnsubscribe, ping, ping, proceed, proceedWithPatterns, psubscribe, punsubscribe, punsubscribe, subscribe, unsubscribe, unsubscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CacheInvalidationSubscriber

public CacheInvalidationSubscriber(Consumer<String> onInvalidate)

Method Details

onSubscribe

public void onSubscribe(String channel,
 int subscribedChannels)

Overrides:

onSubscribe in class redis.clients.jedis.JedisPubSubBase<String>

awaitSubscribed

public boolean awaitSubscribed(long timeout,
 TimeUnit unit)
                        throws InterruptedException

Throws:

InterruptedException

onMessage

public void onMessage(String channel,
 String message)

Overrides:

onMessage in class redis.clients.jedis.JedisPubSubBase<String>