Package 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 CachingRMICachePeerManager.Key. If there is no CachingRMICachePeerManager.Value for CachingRMICachePeerManager.Key it is computed. If the Node which was used to compute CachingRMICachePeerManager.Value.cachePeer has changed (is not equal) the CachingRMICachePeerManager.Value.cachePeer will be re-computed and CachingRMICachePeerManager.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

invalid reference

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	Description
CachingRMICachePeerManager(RMICachePeerProvider rmiCachePeerProvider)

Method Summary

Modifier and Type	Method	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 Details

CachingRMICachePeerManager

public CachingRMICachePeerManager(RMICachePeerProvider rmiCachePeerProvider)

Method Details

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