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

Class RMICachePeer

java.lang.Object

java.rmi.server.RemoteObject

java.rmi.server.RemoteServer

java.rmi.server.UnicastRemoteObject

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

All Implemented Interfaces:

Serializable, Remote, net.sf.ehcache.distribution.CachePeer

public class RMICachePeer
extends UnicastRemoteObject
implements net.sf.ehcache.distribution.CachePeer, Remote

An RMI based implementation of CachePeer.

This class features a customised RMIClientSocketFactory which enables socket timeouts to be configured.

Version:

$Id$

Author:

Greg Luck

See Also:

Serialized Form

Field Summary

Fields inherited from class java.rmi.server.RemoteObject

ref

Constructor Summary

Constructors

Constructor and Description
RMICachePeer(net.sf.ehcache.Ehcache cache, String hostName, Integer rmiRegistryPort, Integer remoteObjectPort, Integer socketTimeoutMillis) Construct a new remote peer.

Method Summary

Modifier and Type	Method and Description
List	getElements(List keys) Gets a list of elements from the cache, for a list of keys, without updating Element statistics.
String	getGuid()
List	getKeys() Returns a list of all elements in the cache, whether or not they are expired.
String	getName() Gets the cache name
net.sf.ehcache.Element	getQuiet(Serializable key) Gets an element from the cache, without updating Element statistics.
String	getUrl() This implementation gives an URL which has meaning to the RMI remoting system.
String	getUrlBase() This implementation gives an URL which has meaning to the RMI remoting system.
void	put(net.sf.ehcache.Element element) Puts an Element into the underlying cache without notifying listeners or updating statistics.
boolean	remove(Serializable key) Removes an Element from the underlying cache without notifying listeners or updating statistics.
void	removeAll() Removes all cached items.
void	send(List eventMessages) Send the cache peer with an ordered list of EventMessages This enables multiple messages to be delivered in one network invocation.
String	toString() Returns a String that represents the value of this object.

Methods inherited from class java.rmi.server.UnicastRemoteObject

clone, exportObject, exportObject, exportObject, unexportObject

Methods inherited from class java.rmi.server.RemoteServer

getClientHost, getLog, setLog

Methods inherited from class java.rmi.server.RemoteObject

equals, getRef, hashCode, toStub

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

RMICachePeer

public RMICachePeer(net.sf.ehcache.Ehcache cache,
                    String hostName,
                    Integer rmiRegistryPort,
                    Integer remoteObjectPort,
                    Integer socketTimeoutMillis)
             throws RemoteException

Construct a new remote peer.

Parameters:

cache - The cache attached to the peer

hostName - The host name the peer is running on.

rmiRegistryPort - The port number on which the RMI Registry listens. Should be an unused port in the range 1025 - 65536

remoteObjectPort - the port number on which the remote objects bound in the registry receive calls. This defaults to a free port if not specified. Should be an unused port in the range 1025 - 65536

socketTimeoutMillis -

Throws:

RemoteException

Method Detail

getUrl

public final String getUrl()

This implementation gives an URL which has meaning to the RMI remoting system.

Specified by:

getUrl in interface net.sf.ehcache.distribution.CachePeer

Returns:

the URL, without the scheme, as a string e.g. //hostname:port/cacheName

getUrlBase

public final String getUrlBase()

This implementation gives an URL which has meaning to the RMI remoting system.

Specified by:

getUrlBase in interface net.sf.ehcache.distribution.CachePeer

Returns:

the URL, without the scheme, as a string e.g. //hostname:port

getKeys

public List getKeys()
             throws RemoteException

Returns a list of all elements in the cache, whether or not they are expired.

The returned keys are unique and can be considered a set.

The List returned is not live. It is a copy.

The time taken is O(n). On a single cpu 1.8Ghz P4, approximately 8ms is required for each 1000 entries.

Specified by:

getKeys in interface net.sf.ehcache.distribution.CachePeer

Returns:

a list of Object keys

Throws:

RemoteException

getQuiet

public net.sf.ehcache.Element getQuiet(Serializable key)
                                throws RemoteException

Gets an element from the cache, without updating Element statistics. Cache statistics are still updated.

Specified by:

getQuiet in interface net.sf.ehcache.distribution.CachePeer

Parameters:

key - a serializable value

Returns:

the element, or null, if it does not exist.

Throws:

RemoteException

getElements

public List getElements(List keys)
                 throws RemoteException

Gets a list of elements from the cache, for a list of keys, without updating Element statistics. Time to idle lifetimes are therefore not affected.

Cache statistics are still updated.

Callers should ideally first call this method with a small list of keys to gauge the size of a typical Element. Then a calculation can be made of the right number to request each time so as to optimise network performance and not cause an OutOfMemory error on this Cache.

Specified by:

getElements in interface net.sf.ehcache.distribution.CachePeer

Parameters:

keys - a list of serializable values which represent keys

Returns:

a list of Elements. If an element was not found or null, it will not be in the list.

Throws:

RemoteException

put

public void put(net.sf.ehcache.Element element)
         throws RemoteException,
                IllegalArgumentException,
                IllegalStateException

Puts an Element into the underlying cache without notifying listeners or updating statistics.

Specified by:

put in interface net.sf.ehcache.distribution.CachePeer

Parameters:

element -

Throws:

RemoteException

IllegalArgumentException

IllegalStateException

remove

public boolean remove(Serializable key)
               throws RemoteException,
                      IllegalStateException

Removes an Element from the underlying cache without notifying listeners or updating statistics.

Specified by:

remove in interface net.sf.ehcache.distribution.CachePeer

Parameters:

key -

Returns:

true if the element was removed, false if it was not found in the cache

Throws:

RemoteException

IllegalStateException

removeAll

public void removeAll()
               throws RemoteException,
                      IllegalStateException

Removes all cached items.

Specified by:

removeAll in interface net.sf.ehcache.distribution.CachePeer

Throws:

IllegalStateException - if the cache is not Status.STATUS_ALIVE

RemoteException

send

public void send(List eventMessages)
          throws RemoteException

Send the cache peer with an ordered list of EventMessages

This enables multiple messages to be delivered in one network invocation.

Specified by:

send in interface net.sf.ehcache.distribution.CachePeer

Throws:

RemoteException

getName

public final String getName()
                     throws RemoteException

Gets the cache name

Specified by:

getName in interface net.sf.ehcache.distribution.CachePeer

Throws:

RemoteException

getGuid

public final String getGuid()
                     throws RemoteException

Specified by:

getGuid in interface net.sf.ehcache.distribution.CachePeer

Throws:

RemoteException

toString

public String toString()

Returns a String that represents the value of this object.

Overrides:

toString in class RemoteObject