com.atlassian.jira.cluster.distribution

Class JiraCacheManagerPeerProvider

java.lang.Object

net.sf.ehcache.distribution.RMICacheManagerPeerProvider

com.atlassian.jira.cluster.distribution.JiraCacheManagerPeerProvider

All Implemented Interfaces:

net.sf.ehcache.distribution.CacheManagerPeerProvider

public class JiraCacheManagerPeerProvider
extends net.sf.ehcache.distribution.RMICacheManagerPeerProvider

Jira Cache Manager Peer Provider This provider will match with the cluster manager to get all the live nodes and build the proper rmi points where to propagate the information

Since:

6.3.4

Field Summary

Fields inherited from class net.sf.ehcache.distribution.RMICacheManagerPeerProvider

cacheManager, peerUrls

Constructor Summary

Constructors

Constructor and Description
JiraCacheManagerPeerProvider(net.sf.ehcache.CacheManager cacheManager, ExecutorService executorService, RMIClientSocketFactory rmiClientSocketFactory)

Method Summary

Modifier and Type	Method and Description
long	getTimeForClusterToForm()
void	init()
List<net.sf.ehcache.distribution.CachePeer>	listRemoteCachePeers(net.sf.ehcache.Ehcache cache)
protected net.sf.ehcache.distribution.CachePeer	lookupRemoteCachePeer(Node node, String cacheName)
void	registerPeer(String rmiUrl)
protected boolean	stale(Date date)

Methods inherited from class net.sf.ehcache.distribution.RMICacheManagerPeerProvider

dispose, getCacheManager, getScheme, lookupRemoteCachePeer, unregisterPeer

Methods inherited from class java.lang.Object

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

Constructor Detail

JiraCacheManagerPeerProvider

public JiraCacheManagerPeerProvider(net.sf.ehcache.CacheManager cacheManager,
                                    ExecutorService executorService,
                                    RMIClientSocketFactory rmiClientSocketFactory)

Method Detail

init

public void init()

Specified by:

init in interface net.sf.ehcache.distribution.CacheManagerPeerProvider

Specified by:

init in class net.sf.ehcache.distribution.RMICacheManagerPeerProvider

getTimeForClusterToForm

public long getTimeForClusterToForm()

registerPeer

public final void registerPeer(String rmiUrl)

Specified by:

registerPeer in interface net.sf.ehcache.distribution.CacheManagerPeerProvider

Specified by:

registerPeer in class net.sf.ehcache.distribution.RMICacheManagerPeerProvider

listRemoteCachePeers

public List<net.sf.ehcache.distribution.CachePeer> listRemoteCachePeers(net.sf.ehcache.Ehcache cache)
                                                                 throws net.sf.ehcache.CacheException

Specified by:

listRemoteCachePeers in interface net.sf.ehcache.distribution.CacheManagerPeerProvider

Specified by:

listRemoteCachePeers in class net.sf.ehcache.distribution.RMICacheManagerPeerProvider

Throws:

net.sf.ehcache.CacheException

lookupRemoteCachePeer

protected net.sf.ehcache.distribution.CachePeer lookupRemoteCachePeer(Node node,
                                                                      String cacheName)
                                                               throws NotBoundException,
                                                                      RemoteException

Throws:

NotBoundException

RemoteException

stale

protected boolean stale(Date date)

Specified by:

stale in class net.sf.ehcache.distribution.RMICacheManagerPeerProvider