com.atlassian.jira.cluster.distribution.localq.rmi

Class CachingRMICachePeerManager

java.lang.Object

com.atlassian.jira.cluster.distribution.localq.rmi.CachingRMICachePeerManager

All Implemented Interfaces:

RMICachePeerManager

public class CachingRMICachePeerManager
extends Object
implements RMICachePeerManager

CachePeer cache. CachePeer is cached per nodeId and cacheName Key. If there is no Value for Key it is computed. If the Node which was used to compute Value#cachePeer has changed (is not equal) the Value#cachePeer will be re-computed and Value#node set to new node. If there were errors (NotBoundException or RemoteException) when getting or using given CachePeer it will be removed from cache and re-created on next request. Service defined in com.atlassian.jira.ClusterServicesRegistrar only available in clustered jira and when LocalQConfig.isLocalQReplicationDisabled() is false.

Nested Class Summary

Nested classes/interfaces inherited from interface com.atlassian.jira.cluster.distribution.localq.rmi.RMICachePeerManager

RMICachePeerManager.CachePeerCallable

Constructor Summary

Constructors

Constructor and Description
CachingRMICachePeerManager(RMICachePeerProvider rmiCachePeerProvider)

Method Summary

Modifier and Type	Method and Description
void	withCachePeer(Node node, String cacheName, RMICachePeerManager.CachePeerCallable cachePeerCallable) Provides access to a CachePeer inside RMICachePeerManager.CachePeerCallable for a given Node and cacheName.

Methods inherited from class java.lang.Object

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

Constructor Detail

CachingRMICachePeerManager

public CachingRMICachePeerManager(RMICachePeerProvider rmiCachePeerProvider)

Method Detail

withCachePeer

public void withCachePeer(Node node,
                          String cacheName,
                          RMICachePeerManager.CachePeerCallable cachePeerCallable)
                   throws NotBoundException,
                          RemoteException

Description copied from interface: RMICachePeerManager

Provides access to a CachePeer inside RMICachePeerManager.CachePeerCallable for a given Node and cacheName. RMICachePeerManager.CachePeerCallable is invoked synchronously.

Specified by:

withCachePeer in interface RMICachePeerManager

Throws:

NotBoundException

RemoteException