Package org.redisson.cache

Class LocalCacheListener

java.lang.Object

org.redisson.cache.LocalCacheListener

public abstract class LocalCacheListener
extends Object

Author:

Nikita Koksharov

Field Summary

Fields

Modifier and Type	Field	Description
static String	DISABLED_ACK_SUFFIX
static String	DISABLED_KEYS_SUFFIX
static String	TOPIC_SUFFIX

Constructor Summary

Constructors

Constructor	Description
LocalCacheListener(String name, CommandAsyncExecutor commandExecutor, RObject object, Codec codec, LocalCachedMapOptions<?,?> options, long cacheUpdateLogTime)

Method Summary

Modifier and Type	Method	Description
void	add(Map<?,?> cache)
RFuture<Void>	clearLocalCacheAsync()
ConcurrentMap<CacheKey,CacheValue>	createCache(LocalCachedMapOptions<?,?> options)
byte[]	generateId()
byte[]	getInstanceId()
RTopic	getInvalidationTopic()
String	getInvalidationTopicName()
String	getUpdatesLogName()
boolean	isDisabled(Object key)
void	remove()
protected abstract void	updateCache(io.netty.buffer.ByteBuf keyBuf, io.netty.buffer.ByteBuf valueBuf)

Methods inherited from class java.lang.Object

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

Field Detail

TOPIC_SUFFIX

public static final String TOPIC_SUFFIX

See Also:

Constant Field Values

DISABLED_KEYS_SUFFIX

public static final String DISABLED_KEYS_SUFFIX

See Also:

Constant Field Values

DISABLED_ACK_SUFFIX

public static final String DISABLED_ACK_SUFFIX

See Also:

Constant Field Values

Constructor Detail

LocalCacheListener

public LocalCacheListener(String name,
                          CommandAsyncExecutor commandExecutor,
                          RObject object,
                          Codec codec,
                          LocalCachedMapOptions<?,?> options,
                          long cacheUpdateLogTime)

Method Detail

generateId

public byte[] generateId()

getInstanceId

public byte[] getInstanceId()

createCache

public ConcurrentMap<CacheKey,CacheValue> createCache(LocalCachedMapOptions<?,?> options)

isDisabled

public boolean isDisabled(Object key)

add

public void add(Map<?,?> cache)

clearLocalCacheAsync

public RFuture<Void> clearLocalCacheAsync()

getInvalidationTopic

public RTopic getInvalidationTopic()

getInvalidationTopicName

public String getInvalidationTopicName()

updateCache

protected abstract void updateCache(io.netty.buffer.ByteBuf keyBuf,
                                    io.netty.buffer.ByteBuf valueBuf)
                             throws IOException

Throws:

IOException

remove

public void remove()

getUpdatesLogName

public String getUpdatesLogName()