org.jivesoftware.util.cache
Class DefaultLocalCacheStrategy

java.lang.Object
  org.jivesoftware.util.cache.DefaultLocalCacheStrategy

All Implemented Interfaces:

CacheFactoryStrategy

public class DefaultLocalCacheStrategy
extends Object
implements CacheFactoryStrategy

CacheFactoryStrategy for use in Openfire. It creates and manages local caches, and it's cluster related method implementations do nothing.

See Also:

Cache, CacheFactory

Field Summary

static long	DEFAULT_MAX_CACHE_LIFETIME
static int	DEFAULT_MAX_CACHE_SIZE

Constructor Summary

DefaultLocalCacheStrategy()

Method Summary

Cache	createCache(String name) Creates a new cache for the cache name specified.
void	doClusterTask(ClusterTask task) Invokes a task on other cluster members in an asynchronous fashion.
boolean	doClusterTask(ClusterTask task, byte[] nodeID) Invokes a task on other the specified cluster member in an asynchronous fashion.
Collection<Object>	doSynchronousClusterTask(ClusterTask task, boolean includeLocalMember) Invokes a task on other cluster members synchronously and returns the result as a Collection (method will not return until the task has been executed on each cluster member).
Object	doSynchronousClusterTask(ClusterTask task, byte[] nodeID) Invokes a task on a given cluster member synchronously and returns the result of the remote operation.
byte[]	getClusterMemberID() Returns a byte[] that uniquely identifies this member within the cluster or null when not in a cluster.
Collection<ClusterNodeInfo>	getClusterNodesInfo() Returns basic information about the current members of the cluster or an empty collection if not running in a cluster.
int	getMaxClusterNodes() Returns the maximum number of cluster members allowed.
byte[]	getSeniorClusterMemberID() Returns a byte[] that uniquely identifies this senior cluster member or null when not in a cluster.
boolean	isSeniorClusterMember() Returns true if this node is the maste node of the cluster.
void	lockKey(Object key, long timeout) Locks the specified key in the locking map.
static void	setMaxLifetimeProperty(String cacheName, long lifetime) Sets a local property which overrides the maximum cache entry lifetime as configured in coherence-cache-config.xml for the supplied cache name.
static void	setMaxSizeProperty(String cacheName, int size) Sets a local property which overrides the maximum cache size as configured in coherence-cache-config.xml for the supplied cache name.
boolean	startCluster() Returns true if the cluster has been started.
void	stopCluster() Stops the cluster.
void	unlockKey(Object key) Unlocks the specified key in the locking map.
void	updateCacheStats(Map<String,Cache> caches) Updates the statistics of the specified caches and publishes them into a cache for statistics.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAX_CACHE_SIZE

public static final int DEFAULT_MAX_CACHE_SIZE

See Also:

Constant Field Values

DEFAULT_MAX_CACHE_LIFETIME

public static final long DEFAULT_MAX_CACHE_LIFETIME

See Also:

Constant Field Values

Constructor Detail

DefaultLocalCacheStrategy

public DefaultLocalCacheStrategy()

Method Detail

startCluster

public boolean startCluster()

Description copied from interface: CacheFactoryStrategy

Returns true if the cluster has been started. When running in local mode a true value should be returned.

An error should be logged when the cluster fails to be started.

Specified by:

startCluster in interface CacheFactoryStrategy

Returns:

true if the cluster has been started.

stopCluster

public void stopCluster()

Description copied from interface: CacheFactoryStrategy

Stops the cluster. When not running in a cluster this request will be ignored.

Specified by:

stopCluster in interface CacheFactoryStrategy

createCache

public Cache createCache(String name)

Description copied from interface: CacheFactoryStrategy

Creates a new cache for the cache name specified. The created cache is already configured. Different implementations could store the cache configuration in different ways. It is recommended to store the cache configuration in an external file so it is easier for customers to change the default configuration.

Specified by:

createCache in interface CacheFactoryStrategy

Parameters:

name - name of the cache to create.

Returns:

newly created and configured cache.

isSeniorClusterMember

public boolean isSeniorClusterMember()

Description copied from interface: CacheFactoryStrategy

Returns true if this node is the maste node of the cluster. When not running in cluster mode a value of true should be returned.

Specified by:

isSeniorClusterMember in interface CacheFactoryStrategy

Returns:

true if this node is the maste node of the cluster.

getClusterNodesInfo

public Collection<ClusterNodeInfo> getClusterNodesInfo()

Description copied from interface: CacheFactoryStrategy

Returns basic information about the current members of the cluster or an empty collection if not running in a cluster.

Specified by:

getClusterNodesInfo in interface CacheFactoryStrategy

Returns:

information about the current members of the cluster or an empty collection if not running in a cluster.

getMaxClusterNodes

public int getMaxClusterNodes()

Description copied from interface: CacheFactoryStrategy

Returns the maximum number of cluster members allowed. A value of 0 will be returned when clustering is not allowed.

Specified by:

getMaxClusterNodes in interface CacheFactoryStrategy

Returns:

the maximum number of cluster members allowed or 0 if clustering is not allowed.

getSeniorClusterMemberID

public byte[] getSeniorClusterMemberID()

Description copied from interface: CacheFactoryStrategy

Returns a byte[] that uniquely identifies this senior cluster member or null when not in a cluster.

Specified by:

getSeniorClusterMemberID in interface CacheFactoryStrategy

Returns:

a byte[] that uniquely identifies this senior cluster member or null when not in a cluster.

getClusterMemberID

public byte[] getClusterMemberID()

Description copied from interface: CacheFactoryStrategy

Returns a byte[] that uniquely identifies this member within the cluster or null when not in a cluster.

Specified by:

getClusterMemberID in interface CacheFactoryStrategy

Returns:

a byte[] that uniquely identifies this member within the cluster or null when not in a cluster.

doClusterTask

public void doClusterTask(ClusterTask task)

Description copied from interface: CacheFactoryStrategy

Invokes a task on other cluster members in an asynchronous fashion. The task will not be executed on the local cluster member. If clustering is not enabled, this method will do nothing.

Specified by:

doClusterTask in interface CacheFactoryStrategy

Parameters:

task - the task to be invoked on all other cluster members.

doClusterTask

public boolean doClusterTask(ClusterTask task,
                             byte[] nodeID)

Description copied from interface: CacheFactoryStrategy

Invokes a task on other the specified cluster member in an asynchronous fashion. If clustering is not enabled, this method will do nothing.

Specified by:

doClusterTask in interface CacheFactoryStrategy

Parameters:

task - the task to be invoked on the specified cluster member.

nodeID - the byte array that identifies the target cluster member.

Returns:

false if not in a cluster or specified cluster node was not found.

doSynchronousClusterTask

public Collection<Object> doSynchronousClusterTask(ClusterTask task,
                                                   boolean includeLocalMember)

Description copied from interface: CacheFactoryStrategy

Invokes a task on other cluster members synchronously and returns the result as a Collection (method will not return until the task has been executed on each cluster member). The task will not be executed on the local cluster member. If clustering is not enabled, this method will return an empty collection.

Specified by:

doSynchronousClusterTask in interface CacheFactoryStrategy

Parameters:

task - the ClusterTask object to be invoked on all other cluster members.

includeLocalMember - true to run the task on the local member, false otherwise

Returns:

collection with the result of the execution.

doSynchronousClusterTask

public Object doSynchronousClusterTask(ClusterTask task,
                                       byte[] nodeID)

Description copied from interface: CacheFactoryStrategy

Invokes a task on a given cluster member synchronously and returns the result of the remote operation. If clustering is not enabled, this method will return null.

Specified by:

doSynchronousClusterTask in interface CacheFactoryStrategy

Parameters:

task - the ClusterTask object to be invoked on a given cluster member.

nodeID - the byte array that identifies the target cluster member.

Returns:

result of remote operation or null if operation failed or operation returned null.

updateCacheStats

public void updateCacheStats(Map<String,Cache> caches)

Description copied from interface: CacheFactoryStrategy

Updates the statistics of the specified caches and publishes them into a cache for statistics. The statistics cache is already known to the application but this could change in the future (?). When not in cluster mode then do nothing.

The statistics cache must contain a long array of 5 positions for each cache with the following content:

1. cache.getCacheSize()
2. cache.getMaxCacheSize()
3. cache.size()
4. cache.getCacheHits()
5. cache.getCacheMisses()

Specified by:

updateCacheStats in interface CacheFactoryStrategy

Parameters:

caches - caches to get their stats and publish them in a statistics cache.

lockKey

public void lockKey(Object key,
                    long timeout)

Description copied from interface: CacheFactoryStrategy

Locks the specified key in the locking map. The map should be clusterable thus locking a key is visible to the cluster. When not in cluster mode the lock is only visible to this JVM.

Specified by:

lockKey in interface CacheFactoryStrategy

Parameters:

key - the key to lock.

timeout - number of milliseconds to wait to obtain the lock. -1 means wait forever.

unlockKey

public void unlockKey(Object key)

Description copied from interface: CacheFactoryStrategy

Unlocks the specified key in the locking map. The map should be clusterable thus locking a key is visible to the cluster. When not in cluster mode the lock is only visible to this JVM.

Specified by:

unlockKey in interface CacheFactoryStrategy

Parameters:

key - the key to unlock.

setMaxSizeProperty

public static void setMaxSizeProperty(String cacheName,
                                      int size)

Sets a local property which overrides the maximum cache size as configured in coherence-cache-config.xml for the supplied cache name.

Parameters:

cacheName - the name of the cache to store a value for.

size - the maximum cache size.

setMaxLifetimeProperty

public static void setMaxLifetimeProperty(String cacheName,
                                          long lifetime)

Sets a local property which overrides the maximum cache entry lifetime as configured in coherence-cache-config.xml for the supplied cache name.

Parameters:

cacheName - the name of the cache to store a value for.

lifetime - the maximum cache entry lifetime.