Package com.helix.core.cache.l4

Class RedisCacheInvalidator

java.lang.Object

com.helix.core.cache.l4.RedisCacheInvalidator

public class RedisCacheInvalidator
extends Object

Publisher for broadcasting cache invalidation events across cluster nodes via Redis Pub/Sub.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_INVALIDATION_CHANNEL

Constructor Summary

Constructors

Constructor	Description
RedisCacheInvalidator(redis.clients.jedis.JedisPool jedisPool)
RedisCacheInvalidator(redis.clients.jedis.JedisPool jedisPool, String channel)

Method Summary

Modifier and Type	Method	Description
void	broadcastInvalidation(CacheKey key)	Broadcasts an invalidation event using a CacheKey.
void	broadcastInvalidation(String ruleName)	Broadcasts an invalidation event for the specified rule name.
String	getChannel()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_INVALIDATION_CHANNEL

public static final String DEFAULT_INVALIDATION_CHANNEL

See Also:

• Constant Field Values

Constructor Details

RedisCacheInvalidator

public RedisCacheInvalidator(redis.clients.jedis.JedisPool jedisPool)

RedisCacheInvalidator

public RedisCacheInvalidator(redis.clients.jedis.JedisPool jedisPool,
 String channel)

Method Details

broadcastInvalidation

public void broadcastInvalidation(String ruleName)

Broadcasts an invalidation event for the specified rule name.

Parameters:

ruleName - name of the rule to invalidate across the cluster

broadcastInvalidation

public void broadcastInvalidation(CacheKey key)

Broadcasts an invalidation event using a CacheKey.

Parameters:

key - cache key of the rule

getChannel

public String getChannel()