com.liferay.portal.cache.ehcache
Class JGroupsManager

java.lang.Object
  com.liferay.portal.cache.ehcache.JGroupsManager

All Implemented Interfaces:

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

public class JGroupsManager
extends Object
implements net.sf.ehcache.distribution.CacheManagerPeerProvider, net.sf.ehcache.distribution.CachePeer

See http://issues.liferay.com/browse/LPS-11061.

Constructor Summary

JGroupsManager(net.sf.ehcache.CacheManager cacheManager, String clusterName, String channelProperties)

Method Summary

void	dispose()
org.jgroups.Address	getBusLocalAddress()
List<org.jgroups.Address>	getBusMembership()
List	getElements(List list)
String	getGuid()
List	getKeys()
String	getName()
net.sf.ehcache.Element	getQuiet(Serializable serializable)
String	getScheme()
long	getTimeForClusterToForm()
String	getUrl()
String	getUrlBase()
protected void	handleJGroupsNotification(net.sf.ehcache.distribution.jgroups.JGroupEventMessage jGroupEventMessage)
void	handleNotification(Serializable serializable)
void	init()
List<JGroupsManager>	listRemoteCachePeers(net.sf.ehcache.Ehcache ehcache)
void	put(net.sf.ehcache.Element element)
void	registerPeer(String string)
boolean	remove(Serializable serializable)
void	removeAll()
void	send(org.jgroups.Address address, List eventMessages)
void	send(List eventMessages)
void	unregisterPeer(String string)

Methods inherited from class java.lang.Object

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

Constructor Detail

JGroupsManager

public JGroupsManager(net.sf.ehcache.CacheManager cacheManager,
                      String clusterName,
                      String channelProperties)

Method Detail

dispose

public void dispose()
             throws net.sf.ehcache.CacheException

Specified by:

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

Throws:

net.sf.ehcache.CacheException

getBusLocalAddress

public org.jgroups.Address getBusLocalAddress()

getBusMembership

public List<org.jgroups.Address> getBusMembership()

getElements

public List getElements(List list)

Specified by:

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

getGuid

public String getGuid()

Specified by:

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

getKeys

public List getKeys()

Specified by:

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

getName

public String getName()

Specified by:

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

getQuiet

public net.sf.ehcache.Element getQuiet(Serializable serializable)

Specified by:

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

getScheme

public String getScheme()

Specified by:

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

getTimeForClusterToForm

public long getTimeForClusterToForm()

Specified by:

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

getUrl

public String getUrl()

Specified by:

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

getUrlBase

public String getUrlBase()

Specified by:

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

handleNotification

public void handleNotification(Serializable serializable)

init

public void init()

Specified by:

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

listRemoteCachePeers

public List<JGroupsManager> listRemoteCachePeers(net.sf.ehcache.Ehcache ehcache)

Specified by:

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

put

public void put(net.sf.ehcache.Element element)

Specified by:

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

registerPeer

public void registerPeer(String string)

Specified by:

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

remove

public boolean remove(Serializable serializable)

Specified by:

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

removeAll

public void removeAll()

Specified by:

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

send

public void send(org.jgroups.Address address,
                 List eventMessages)
          throws RemoteException

Throws:

RemoteException

send

public void send(List eventMessages)
          throws RemoteException

Specified by:

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

Throws:

RemoteException

unregisterPeer

public void unregisterPeer(String string)

Specified by:

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

handleJGroupsNotification

protected void handleJGroupsNotification(net.sf.ehcache.distribution.jgroups.JGroupEventMessage jGroupEventMessage)