Package org.redisson.cache

Class LocalCacheListener

org.redisson.cache.LocalCacheListener

public abstract class LocalCacheListener
extends 

Author:

Nikita Koksharov

Field Summary

Fields

Modifier and Type	Field	Description
static	DISABLED_ACK_SUFFIX
static	DISABLED_KEYS_SUFFIX
static	TOPIC_SUFFIX

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.

, , , , , , , , , ,

Field Detail

TOPIC_SUFFIX

public static final  TOPIC_SUFFIX

See Also:

Constant Field Values

DISABLED_KEYS_SUFFIX

public static final  DISABLED_KEYS_SUFFIX

See Also:

Constant Field Values

DISABLED_ACK_SUFFIX

public static final  DISABLED_ACK_SUFFIX

See Also:

Constant Field Values

Constructor Detail

LocalCacheListener

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

Method Detail

generateId

public byte[] generateId()

getInstanceId

public byte[] getInstanceId()

createCache

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

isDisabled

public boolean isDisabled( key)

add

public void add(<?,?> cache)

clearLocalCacheAsync

public > clearLocalCacheAsync()

getInvalidationTopic

public RTopic getInvalidationTopic()

getInvalidationTopicName

public  getInvalidationTopicName()

updateCache

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

Throws:

remove

public void remove()

getUpdatesLogName

public  getUpdatesLogName()